Lines Matching refs:multiprocessing

11 import multiprocessing               # may get overwritten
21     print '\n\t\t\t' + str(multiprocessing.current_process()) + ' has finished'
27     running = multiprocessing.Value('i', TASKS)
28     mutex = multiprocessing.Lock()
31         p = multiprocessing.Process(target=value_func, args=(running, mutex))
54     q = multiprocessing.Queue()
56     p = multiprocessing.Process(target=queue_func, args=(q,))
83     cond = multiprocessing.Condition()
85     p = multiprocessing.Process(target=condition_func, args=(cond,))
123     print '%s has finished' % multiprocessing.current_process()
129     sema = multiprocessing.Semaphore(3)
130     mutex = multiprocessing.RLock()
131     running = multiprocessing.Value('i', 0)
134         multiprocessing.Process(target=semaphore_func,
154     p = multiprocessing.Process(target=join_timeout_func)
170     print '\t%r is waiting' % multiprocessing.current_process()
172     print '\t%r has woken up' % multiprocessing.current_process()
175     event = multiprocessing.Event()
177     processes = [multiprocessing.Process(target=event_func, args=(event,))
220     shared_values = [multiprocessing.Value(id, v) for id, v in values]
221     shared_arrays = [multiprocessing.Array(id, a) for id, a in arrays]
223     p = multiprocessing.Process(
235 def test(namespace=multiprocessing):
236     global multiprocessing
238     multiprocessing = namespace
247     ignore = multiprocessing.active_children()      # cleanup any old processes
248     if hasattr(multiprocessing, '_debug_info'):
249         info = multiprocessing._debug_info()
256     multiprocessing.freeze_support()
262         namespace = multiprocessing
265         namespace = multiprocessing.Manager()
266         namespace.Process = multiprocessing.Process
267         namespace.current_process = multiprocessing.current_process
268         namespace.active_children = multiprocessing.active_children
271         import multiprocessing.dummy as namespace