Mercurial Repositories > Radon Code Metrics / file comparison
comparison: RadonMetrics/CodeMetricsCalculator.py
RadonMetrics/CodeMetricsCalculator.py
- changeset 69
- cdf51e6abaee
- parent 68
- 69445de59a30
- child 75
- e7ed383ac6a7
equal
deleted
inserted
replaced
| 68:69445de59a30 | 69:cdf51e6abaee |
|---|---|
| 5 | 5 |
| 6 """ | 6 """ |
| 7 Module implementing the raw code metrics service. | 7 Module implementing the raw code metrics service. |
| 8 """ | 8 """ |
| 9 | 9 |
| 10 from __future__ import unicode_literals | 10 import queue |
| 11 | |
| 12 try: | |
| 13 str = unicode # __IGNORE_EXCEPTION__ __IGNORE_WARNING__ | |
| 14 except NameError: | |
| 15 pass | |
| 16 | |
| 17 try: | |
| 18 import Queue as queue # Py2 | |
| 19 except ImportError: | |
| 20 import queue | |
| 21 | |
| 22 import multiprocessing | 11 import multiprocessing |
| 23 | 12 |
| 24 | 13 |
| 25 def initService(): | 14 def initService(): |
| 26 """ | 15 """ |
| 89 for task in argumentsList[:initialTasks]: | 78 for task in argumentsList[:initialTasks]: |
| 90 taskQueue.put(task) | 79 taskQueue.put(task) |
| 91 | 80 |
| 92 # Start worker processes | 81 # Start worker processes |
| 93 for _ in range(NumberOfProcesses): | 82 for _ in range(NumberOfProcesses): |
| 94 multiprocessing.Process(target=worker, args=(taskQueue, doneQueue))\ | 83 multiprocessing.Process( |
| 95 .start() | 84 target=worker, args=(taskQueue, doneQueue)).start() |
| 96 | 85 |
| 97 # Get and send results | 86 # Get and send results |
| 98 endIndex = len(argumentsList) - initialTasks | 87 endIndex = len(argumentsList) - initialTasks |
| 99 for i in range(len(argumentsList)): | 88 for i in range(len(argumentsList)): |
| 100 resultSent = False | 89 resultSent = False |
