RadonMetrics/MaintainabilityIndexCalculator.py

changeset 43
53dbd4f4d6c2
parent 42
04457b4ceda5
child 45
0f2eabfd5834
equal deleted inserted replaced
42:04457b4ceda5 43:53dbd4f4d6c2
100 # Tell child processes to stop 100 # Tell child processes to stop
101 for i in range(NumberOfProcesses): 101 for i in range(NumberOfProcesses):
102 taskQueue.put('STOP') 102 taskQueue.put('STOP')
103 103
104 104
105 def worker(input, output): 105 def worker(inputQueue, outputQueue):
106 """ 106 """
107 Module function acting as the parallel worker for the maintainability 107 Module function acting as the parallel worker for the maintainability
108 index calculation. 108 index calculation.
109 109
110 @param input input queue 110 @param inputQueue input queue
111 @type multiprocessing.Queue 111 @type multiprocessing.Queue
112 @param output output queue 112 @param outputQueue output queue
113 @type multiprocessing.Queue 113 @type multiprocessing.Queue
114 """ 114 """
115 for filename, source in iter(input.get, 'STOP'): 115 for filename, source in iter(inputQueue.get, 'STOP'):
116 result = __maintainabilityIndex(filename, source) 116 result = __maintainabilityIndex(filename, source)
117 output.put((filename, result)) 117 outputQueue.put((filename, result))
118 118
119 119
120 def __maintainabilityIndex(file, text=""): 120 def __maintainabilityIndex(file, text=""):
121 """ 121 """
122 Private function to calculate the maintainability index for one Python 122 Private function to calculate the maintainability index for one Python

eric ide

mercurial