133 valid, if the status is True. |
133 valid, if the status is True. |
134 """ |
134 """ |
135 return __check(file, text) |
135 return __check(file, text) |
136 |
136 |
137 |
137 |
138 def batchCheck(argumentsList, send, fx, cancelled): |
138 def batchCheck(argumentsList, send, fx, cancelled, maxProcesses=0): |
139 """ |
139 """ |
140 Module function to check a batch of files for whitespace related problems. |
140 Module function to check a batch of files for whitespace related problems. |
141 |
141 |
142 @param argumentsList list of arguments tuples as given for check |
142 @param argumentsList list of arguments tuples as given for check |
143 @param send reference to send function (function) |
143 @type list |
144 @param fx registered service name (string) |
144 @param send reference to send function |
|
145 @type func |
|
146 @param fx registered service name |
|
147 @type str |
145 @param cancelled reference to function checking for a cancellation |
148 @param cancelled reference to function checking for a cancellation |
146 (function) |
149 @type func |
147 """ |
150 @param maxProcesses number of processes to be used |
148 try: |
151 @type int |
149 NumberOfProcesses = multiprocessing.cpu_count() |
152 """ |
150 if NumberOfProcesses >= 1: |
153 if maxProcesses == 0: |
151 NumberOfProcesses -= 1 |
154 # determine based on CPU count |
152 except NotImplementedError: |
155 try: |
153 NumberOfProcesses = 1 |
156 NumberOfProcesses = multiprocessing.cpu_count() |
|
157 if NumberOfProcesses >= 1: |
|
158 NumberOfProcesses -= 1 |
|
159 except NotImplementedError: |
|
160 NumberOfProcesses = 1 |
|
161 else: |
|
162 NumberOfProcesses = maxProcesses |
154 |
163 |
155 # Create queues |
164 # Create queues |
156 taskQueue = multiprocessing.Queue() |
165 taskQueue = multiprocessing.Queue() |
157 doneQueue = multiprocessing.Queue() |
166 doneQueue = multiprocessing.Queue() |
158 |
167 |