93 for task in argumentsList[:initialTasks]: |
81 for task in argumentsList[:initialTasks]: |
94 taskQueue.put(task) |
82 taskQueue.put(task) |
95 |
83 |
96 # Start worker processes |
84 # Start worker processes |
97 for _ in range(NumberOfProcesses): |
85 for _ in range(NumberOfProcesses): |
98 multiprocessing.Process(target=worker, args=(taskQueue, doneQueue))\ |
86 multiprocessing.Process( |
99 .start() |
87 target=worker, args=(taskQueue, doneQueue)).start() |
100 |
88 |
101 # Get and send results |
89 # Get and send results |
102 endIndex = len(argumentsList) - initialTasks |
90 endIndex = len(argumentsList) - initialTasks |
103 for i in range(len(argumentsList)): |
91 for i in range(len(argumentsList)): |
104 resultSent = False |
92 resultSent = False |
155 @return tuple containing the result dictionary |
143 @return tuple containing the result dictionary |
156 @rtype (tuple of dict) |
144 @rtype (tuple of dict) |
157 """ |
145 """ |
158 from radon.metrics import mi_visit, mi_rank |
146 from radon.metrics import mi_visit, mi_rank |
159 |
147 |
160 # Check type for py2: if not str it's unicode |
|
161 if sys.version_info[0] == 2: |
|
162 try: |
|
163 text = text.encode('utf-8') |
|
164 except UnicodeError: |
|
165 pass |
|
166 |
|
167 try: |
148 try: |
168 mi = mi_visit(text, True) |
149 mi = mi_visit(text, True) |
169 rank = mi_rank(mi) |
150 rank = mi_rank(mi) |
170 res = {"mi": mi, "rank": rank} |
151 res = {"mi": mi, "rank": rank} |
171 except Exception as err: |
152 except Exception as err: |