| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_contextlib.py | 9 import threading
11 threading = None variable
270 @unittest.skipUnless(threading, 'Threading required for this test.')
285 lock = threading.Lock()
289 lock = threading.RLock()
293 lock = threading.Condition()
299 lock = threading.Semaphore()
309 lock = threading.BoundedSemaphore()
|
| /system/tpm/trunks/ |
| background_command_transceiver_test.cc | 23 #include <base/threading/platform_thread.h>
24 #include <base/threading/thread.h>
|
| /test/framework/harnesses/host_controller/ |
| tfc_host_controller_test.py | 18 import threading
71 run_event = threading.Event()
|
| /test/vts/utils/python/common/ |
| cmd_utils.py | 18 import threading
51 wait_thread = threading.Thread(target=WaitForProcess)
|
| /test/vts-testcase/hal/contexthub/V1_0/host/ |
| VtsHalContexthubV1_0HostTest.py | 19 import threading
30 self.event = threading.Event()
|
| /test/vts-testcase/kernel/ltp/shell_environment/ |
| shell_environment.py | 18 import threading
33 _thread_lock: a threading.Lock object
39 self._thread_lock = threading.Lock()
|
| /external/autotest/client/deps/lansim/src/py/ |
| simulator.py | 10 import threading
279 class SimulatorThread(threading.Thread, Simulator):
302 threading.Thread.__init__(self)
307 self._lock = threading.RLock()
344 lock_cond = threading.Lock()
345 cond_var = threading.Condition(lock_cond)
|
| /external/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/ |
| log.py | 9 import threading
16 _lock = threading.Lock()
23 _tls = threading.local() # tls used to detect forking/etc
87 tid = threading.current_thread().ident
91 "pid": os.getpid(), "tid": threading.current_thread().ident,
155 tid = threading.current_thread().ident
|
| /external/python/cpython3/Lib/ |
| queue.py | 4 import threading
6 import dummy_threading as threading
35 self.mutex = threading.Lock()
39 self.not_empty = threading.Condition(self.mutex)
43 self.not_full = threading.Condition(self.mutex)
47 self.all_tasks_done = threading.Condition(self.mutex)
|
| /external/toolchain-utils/crb/ |
| machine_manager_singleton.py | 4 import threading
32 _lock = threading.RLock()
35 image_lock = threading.Lock()
94 m.autotest_run = threading.current_thread()
99 m.autotest_run = threading.current_thread()
104 m.autotest_run = threading.current_thread()
|
| /external/python/cpython3/Lib/test/libregrtest/ |
| save_env.py | 11 import threading
13 threading = None variable
67 'multiprocessing.process._dangling', 'threading._dangling',
184 if not threading:
187 return threading._dangling.copy()
189 if not threading:
191 threading._dangling.clear()
192 threading._dangling.update(saved)
|
| /external/python/cpython3/Lib/test/ |
| test_sched.py | 6 import threading
8 threading = None variable
15 self._cond = threading.Condition()
61 @unittest.skipUnless(threading, 'Threading required for this test.')
69 t = threading.Thread(target=scheduler.run)
116 @unittest.skipUnless(threading, 'Threading required for this test.')
128 t = threading.Thread(target=scheduler.run)
|
| test_asynchat.py | 17 import threading
19 threading = None variable
25 if threading:
26 class echo_server(threading.Thread):
32 threading.Thread.__init__(self)
99 event = threading.Event()
108 @unittest.skipUnless(threading, 'Threading required for this test.')
119 event = threading.Event()
235 s.start_resend_event = threading.Event(
[all...] |
| ssl_servers.py | 12 threading = support.import_module("threading") variable
120 class HTTPSServerThread(threading.Thread):
128 threading.Thread.__init__(self)
136 threading.Thread.start(self)
157 flag = threading.Event()
|
| /external/v8/tools/testrunner/server/ |
| main.py | 33 import threading
61 self.peer_list_lock = threading.Lock()
82 self.perf_data_lock = threading.Lock()
85 self.local_handler_thread = threading.Thread(
90 self.work_handler_thread = threading.Thread(
95 self.status_handler_thread = threading.Thread(
100 self.presence_daemon_thread = threading.Thread(
|
| /external/python/cpython2/Lib/test/ |
| test_asynchat.py | 12 import threading
14 threading = None variable
19 if threading:
20 class echo_server(threading.Thread):
26 threading.Thread.__init__(self)
94 event = threading.Event()
103 @unittest.skipUnless(threading, 'Threading required for this test.')
114 event = threading.Event()
218 s.start_resend_event = threading.Event(
[all...] |
| ssl_servers.py | 12 threading = support.import_module("threading") variable
120 class HTTPSServerThread(threading.Thread):
128 threading.Thread.__init__(self)
136 threading.Thread.start(self)
157 flag = threading.Event()
|
| /external/python/cpython3/Lib/test/test_importlib/ |
| test_locks.py | 12 import threading
14 threading = None variable
18 if threading is not None:
54 if threading is not None:
76 barrier = threading.Barrier(NTHREADS)
|
| /external/toolchain-utils/automation/server/ |
| job_manager.py | 7 import threading
60 class JobManager(threading.Thread):
63 threading.Thread.__init__(self, name=self.__class__.__name__)
70 self._lock = threading.Lock()
71 self._jobs_available = threading.Condition(self._lock)
|
| /system/core/adb/ |
| test_adb.py | 30 import threading
107 stdout_event = threading.Event()
108 stdout_thread = threading.Thread(
114 stderr_event = threading.Event()
115 stderr_thread = threading.Thread(
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_docxmlrpc.py | 5 threading = test_support.import_module('threading')
variable
76 self.evt = threading.Event()
77 threading.Thread(target=server, args=(self.evt, 1)).start()
|
| /external/autotest/client/common_lib/cros/ |
| retry.py | 9 import threading
196 is_main_thread = isinstance(threading.current_thread(),
197 threading._MainThread)
|
| /external/autotest/client/cros/bluetooth/ |
| output_recorder.py | 14 import threading
72 self._stop_recording_thread_event = threading.Event()
121 self._recording_thread = threading.Thread(target=self.record)
|
| /external/autotest/server/cros/dynamic_suite/ |
| frontend_wrappers.py | 7 import threading
118 if isinstance(threading.current_thread(), threading._MainThread):
|
| /external/autotest/server/cros/ |
| stress.py | 7 import threading
12 class BaseStressor(threading.Thread):
56 Overloaded from threading.Thread. This is run in a separate thread when
128 self._complete = threading.Event()
|
