| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| heap.py | 40 import threading namespace
96 self._lock = threading.Lock()
|
| reduction.py | 41 import threading namespace
96 _lock = threading.Lock()
111 t = threading.Thread(target=_serve)
|
| synchronize.py | 39 import threading namespace
153 if threading.current_thread().name != 'MainThread':
154 name += '|' + threading.current_thread().name
178 if threading.current_thread().name != 'MainThread':
179 name += '|' + threading.current_thread().name
|
| pool.py | 41 import threading namespace
161 self._worker_handler = threading.Thread(
170 self._task_handler = threading.Thread(
178 self._result_handler = threading.Thread(
320 thread = threading.current_thread()
333 thread = threading.current_thread()
372 thread = threading.current_thread()
492 if threading.current_thread() is not worker_handler:
503 if threading.current_thread() is not task_handler:
507 if threading.current_thread() is not result_handler
[all...] |
| queues.py | 39 import threading namespace
88 self._notempty = threading.Condition(threading.Lock())
182 self._thread = threading.Thread(
|
| util.py | 38 import threading # we want threading to install it's namespace
336 self._lock = threading.Lock()
340 class ForkAwareLocal(threading.local):
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_queue.py | 7 threading = test_support.import_module('threading') variable
12 class _TriggerThread(threading.Thread):
16 self.startedEvent = threading.Event()
17 threading.Thread.__init__(self)
88 self.cumlock = threading.Lock()
156 threading.Thread(target=self.worker, args=(q,)).start()
|
| test_threading_local.py | 9 threading = test_support.import_module('threading') variable
32 t = threading.Thread(target=target, args=(local, weaklist))
52 # of a threading.local derived class, the per-thread dictionary
68 t = threading.Thread(target=f, args=(i,))
81 e1 = threading.Event()
82 e2 = threading.Event()
100 t = threading.Thread(target=f)
131 e1 = threading.Event()
132 e2 = threading.Event(
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/dummy/ |
| __init__.py | 45 import threading namespace
53 from threading import Lock, RLock, Semaphore, BoundedSemaphore
54 from threading import Event
61 class DummyProcess(threading.Thread):
64 threading.Thread.__init__(self, group, target, name, args, kwargs)
75 threading.Thread.start(self)
88 class Condition(threading._Condition):
89 notify_all = threading._Condition.notify_all.im_func
96 current_process = threading.current_thread
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| heap.py | 40 import threading namespace
96 self._lock = threading.Lock()
|
| reduction.py | 41 import threading namespace
96 _lock = threading.Lock()
111 t = threading.Thread(target=_serve)
|
| synchronize.py | 39 import threading namespace
153 if threading.current_thread().name != 'MainThread':
154 name += '|' + threading.current_thread().name
178 if threading.current_thread().name != 'MainThread':
179 name += '|' + threading.current_thread().name
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_queue.py | 7 threading = test_support.import_module('threading') variable
12 class _TriggerThread(threading.Thread):
16 self.startedEvent = threading.Event()
17 threading.Thread.__init__(self)
88 self.cumlock = threading.Lock()
156 threading.Thread(target=self.worker, args=(q,)).start()
|
| test_threading_local.py | 9 threading = test_support.import_module('threading') variable
32 t = threading.Thread(target=target, args=(local, weaklist))
52 # of a threading.local derived class, the per-thread dictionary
68 t = threading.Thread(target=f, args=(i,))
81 e1 = threading.Event()
82 e2 = threading.Event()
100 t = threading.Thread(target=f)
131 e1 = threading.Event()
132 e2 = threading.Event(
[all...] |
| /external/chromium/net/tools/testserver/ |
| chromiumsync.py | 17 import threading namespace
707 self.account_lock = threading.Lock()
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| mux_client_for_testing.py | 54 import threading namespace
278 class _MuxReaderThread(threading.Thread):
286 threading.Thread.__init__(self)
392 self._control_blocks_condition = threading.Condition()
395 self._logical_channels_condition = threading.Condition();
729 self._physical_connection_close_event = threading.Event()
|
| /external/chromium_org/build/android/ |
| adb_profile_chrome.py | 15 import threading namespace
167 self._done = threading.Event()
179 self._thread = threading.Thread(target=self._CollectData)
|
| test_runner.py | 16 import threading namespace
795 for thread in threading.enumerate():
|
| /external/chromium_org/chrome/test/pyautolib/ |
| remote_inspector_client.py | 48 import threading namespace
73 is_fulfilled_condition: A threading.Condition for waiting for the request to
90 self.is_fulfilled_condition = threading.Condition()
139 self._socket_buffer_lock = threading.Lock()
274 class _RemoteInspectorThread(threading.Thread):
299 threading.Thread.__init__(self)
306 self._action_queue_condition = threading.Condition()
308 self._action_specific_callback_lock = threading.Lock()
310 self._general_callbacks_lock = threading.Lock()
362 """Start this thread; overridden from threading.Thread.""
[all...] |
| /external/chromium_org/chrome/tools/ |
| webforms_aggregator.py | 34 import threading namespace
595 class WorkerThread(threading.Thread):
606 threading.Thread.__init__(self)
614 names because it is overriding the 'run' method of the 'threading.Thread'
676 originalNumThreads = threading.active_count()
682 while threading.active_count() >= (
685 while threading.active_count() > originalNumThreads:
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/controllers/ |
| layout_test_runner.py | 31 import threading namespace
|
| /external/chromium_org/tools/ |
| bisect-builds.py | 54 import threading namespace
322 @param quit_event A threading.Event which will be set by the master thread to
324 @param progress_event A threading.Event which will be set by the master thread
422 self.quit_event = threading.Event()
423 self.progress_event = threading.Event()
432 self.thread = threading.Thread(target=FetchRevision,
476 Threading is used to fetch Chromium revisions in the background, speeding up
[all...] |
| /external/skia/gm/rebaseline_server/ |
| server.py | 25 import threading namespace
154 self.results_rlock = threading.RLock()
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/ |
| SocketServer.py | 23 - threading (each request is handled by a new thread)
52 Forking and threading versions of each type of server can be created
54 instance, a threading UDP server class is created as follows:
77 you can use a threading server, but you will probably have to use
85 to read all the data it has requested. Here a threading or forking
138 import threading namespace
140 import dummy_threading as threading namespace
210 self.__is_shut_down = threading.Event()
601 t = threading.Thread(target = self.process_request_thread,
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/idlelib/ |
| run.py | 8 import threading namespace
82 sockthread = threading.Thread(target=manage_socket,
163 exclude = ("run.py", "rpc.py", "threading.py", "Queue.py",
245 print>>erf, 'Thread: %s' % threading.currentThread().getName()
|
