Mercurial > piecrust2

comparison piecrust/workerpool.py @ 878:313db67cfc35

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bake: Use the basic Python queue again.
author Ludovic Chabant <ludovic@chabant.com>
date Thu, 15 Jun 2017 22:16:34 -0700
parents 08e02c2a2a1a
children f2b75e4be981
comparison
equal deleted inserted replaced
877:d6d35b2efd04 878:313db67cfc35
11 from piecrust.environment import ExecutionStats 11 from piecrust.environment import ExecutionStats
12 12
13 13
14 logger = logging.getLogger(__name__) 14 logger = logging.getLogger(__name__)
15 15
16 use_fastqueue = True 16 use_fastqueue = False
17 use_fastpickle = False 17 use_fastpickle = False
18 18
19 19
20 class IWorker(object): 20 class IWorker(object):
21 """ Interface for a pool worker. 21 """ Interface for a pool worker.
195 self._quick_put = self._task_queue.put 195 self._quick_put = self._task_queue.put
196 self._quick_get = self._result_queue.get 196 self._quick_get = self._result_queue.get
197 else: 197 else:
198 self._task_queue = multiprocessing.SimpleQueue() 198 self._task_queue = multiprocessing.SimpleQueue()
199 self._result_queue = multiprocessing.SimpleQueue() 199 self._result_queue = multiprocessing.SimpleQueue()
200 self._quick_put = self._task_queue._writer.send 200 self._quick_put = self._task_queue.put
201 self._quick_get = self._result_queue._reader.recv 201 self._quick_get = self._result_queue.get
202 202
203 self._callback = callback 203 self._callback = callback
204 self._error_callback = error_callback 204 self._error_callback = error_callback
205 self._batch_size = batch_size 205 self._batch_size = batch_size
206 self._jobs_left = 0 206 self._jobs_left = 0