149 (bool), fixed (bool), autofixing (bool), fixedMsg (str))) |
149 (bool), fixed (bool), autofixing (bool), fixedMsg (str))) |
150 """ |
150 """ |
151 return __checkCodeStyle(filename, source, args) |
151 return __checkCodeStyle(filename, source, args) |
152 |
152 |
153 |
153 |
154 def codeStyleBatchCheck(argumentsList, send, fx, cancelled): |
154 def codeStyleBatchCheck(argumentsList, send, fx, cancelled, maxProcesses=0): |
155 """ |
155 """ |
156 Module function to check code style for a batch of files. |
156 Module function to check code style for a batch of files. |
157 |
157 |
158 @param argumentsList list of arguments tuples as given for codeStyleCheck |
158 @param argumentsList list of arguments tuples as given for codeStyleCheck |
159 @param send reference to send function (function) |
159 @type list |
160 @param fx registered service name (string) |
160 @param send reference to send function |
|
161 @type func |
|
162 @param fx registered service name |
|
163 @type str |
161 @param cancelled reference to function checking for a cancellation |
164 @param cancelled reference to function checking for a cancellation |
162 (function) |
165 @type func |
163 """ |
166 @param maxProcesses number of processes to be used |
164 try: |
167 @type int |
165 NumberOfProcesses = multiprocessing.cpu_count() |
168 """ |
166 if NumberOfProcesses >= 1: |
169 if maxProcesses == 0: |
167 NumberOfProcesses -= 1 |
170 # determine based on CPU count |
168 except NotImplementedError: |
171 try: |
169 NumberOfProcesses = 1 |
172 NumberOfProcesses = multiprocessing.cpu_count() |
|
173 if NumberOfProcesses >= 1: |
|
174 NumberOfProcesses -= 1 |
|
175 except NotImplementedError: |
|
176 NumberOfProcesses = 1 |
|
177 else: |
|
178 NumberOfProcesses = maxProcesses |
170 |
179 |
171 # Create queues |
180 # Create queues |
172 taskQueue = multiprocessing.Queue() |
181 taskQueue = multiprocessing.Queue() |
173 doneQueue = multiprocessing.Queue() |
182 doneQueue = multiprocessing.Queue() |
174 |
183 |