116 """ |
116 """ |
117 return __syntaxAndPyflakesCheck(filename, codestring, checkFlakes, |
117 return __syntaxAndPyflakesCheck(filename, codestring, checkFlakes, |
118 ignoreStarImportWarnings) |
118 ignoreStarImportWarnings) |
119 |
119 |
120 |
120 |
121 def syntaxAndPyflakesBatchCheck(argumentsList, send, fx, cancelled): |
121 def syntaxAndPyflakesBatchCheck(argumentsList, send, fx, cancelled, |
|
122 maxProcesses=0): |
122 """ |
123 """ |
123 Module function to check syntax for a batch of files. |
124 Module function to check syntax for a batch of files. |
124 |
125 |
125 @param argumentsList list of arguments tuples as given for |
126 @param argumentsList list of arguments tuples as given for |
126 syntaxAndPyflakesCheck |
127 syntaxAndPyflakesCheck |
127 @param send reference to send function (function) |
128 @type list |
128 @param fx registered service name (string) |
129 @param send reference to send function |
|
130 @type func |
|
131 @param fx registered service name |
|
132 @type str |
129 @param cancelled reference to function checking for a cancellation |
133 @param cancelled reference to function checking for a cancellation |
130 (function) |
134 @type func |
131 """ |
135 @param maxProcesses number of processes to be used |
132 try: |
136 @type int |
133 NumberOfProcesses = multiprocessing.cpu_count() |
137 """ |
134 if NumberOfProcesses >= 1: |
138 if maxProcesses == 0: |
135 NumberOfProcesses -= 1 |
139 # determine based on CPU count |
136 except NotImplementedError: |
140 try: |
137 NumberOfProcesses = 1 |
141 NumberOfProcesses = multiprocessing.cpu_count() |
|
142 if NumberOfProcesses >= 1: |
|
143 NumberOfProcesses -= 1 |
|
144 except NotImplementedError: |
|
145 NumberOfProcesses = 1 |
|
146 else: |
|
147 NumberOfProcesses = maxProcesses |
138 |
148 |
139 # Create queues |
149 # Create queues |
140 taskQueue = multiprocessing.Queue() |
150 taskQueue = multiprocessing.Queue() |
141 doneQueue = multiprocessing.Queue() |
151 doneQueue = multiprocessing.Queue() |
142 |
152 |