| /test/vts/testcases/codelab/host_multi_hal/ |
| VtsCodelabHostMultiHalTest.py | 19 import threading
94 t1 = threading.Thread(name='light_test', target=LightWorker)
95 t2 = threading.Thread(name='thermal_test', target=ThermalWorker)
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_smtplib.py | 15 import threading
17 threading = None
variable
43 @unittest.skipUnless(threading, 'Threading required for this test.')
48 self.evt = threading.Event()
53 self.thread = threading.Thread(target=server, args=servargs)
146 @unittest.skipUnless(threading, 'Threading required for this test.')
156 self.serv_evt = threading.Event()
157 self.client_evt = threading.Event()
[all...] |
| 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()
|
| /external/chromium-trace/catapult/devil/devil/android/perf/ |
| surface_stats_collector.py | 6 import threading
37 self._get_data_event = threading.Event()
38 self._stop_event = threading.Event()
40 self._collector_thread = threading.Thread(target=self._CollectorThread)
|
| /external/libbrillo/brillo/message_loops/ |
| message_loop.cc | 9 #include <base/threading/thread_local.h>
|
| /external/libmojo/third_party/catapult/devil/devil/android/perf/ |
| surface_stats_collector.py | 6 import threading
37 self._get_data_event = threading.Event()
38 self._stop_event = threading.Event()
40 self._collector_thread = threading.Thread(target=self._CollectorThread)
|
| /external/python/cpython3/Lib/test/test_tools/ |
| test_sundry.py | 43 @unittest.skipIf(not support.threading, "test requires _thread module")
|
| /external/tensorflow/tensorflow/python/estimator/inputs/queues/ |
| feeding_queue_runner.py | 22 import threading
86 coord.register_thread(threading.current_thread())
159 ret_threads = [threading.Thread(target=self._run,
163 ret_threads.append(threading.Thread(target=self._close_on_stop,
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_smtplib.py | 15 import threading
17 threading = None variable
43 @unittest.skipUnless(threading, 'Threading required for this test.')
48 self.evt = threading.Event()
53 self.thread = threading.Thread(target=server, args=servargs)
146 @unittest.skipUnless(threading, 'Threading required for this test.')
156 self.serv_evt = threading.Event()
157 self.client_evt = threading.Event(
[all...] |
| 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()
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_smtplib.py | 15 import threading
17 threading = None variable
43 @unittest.skipUnless(threading, 'Threading required for this test.')
48 self.evt = threading.Event()
53 self.thread = threading.Thread(target=server, args=servargs)
146 @unittest.skipUnless(threading, 'Threading required for this test.')
156 self.serv_evt = threading.Event()
157 self.client_evt = threading.Event(
[all...] |
| 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()
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_smtplib.py | 15 import threading
17 threading = None variable
43 @unittest.skipUnless(threading, 'Threading required for this test.')
48 self.evt = threading.Event()
53 self.thread = threading.Thread(target=server, args=servargs)
146 @unittest.skipUnless(threading, 'Threading required for this test.')
156 self.serv_evt = threading.Event()
157 self.client_evt = threading.Event(
[all...] |
| 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()
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_smtplib.py | 15 import threading
17 threading = None variable
43 @unittest.skipUnless(threading, 'Threading required for this test.')
48 self.evt = threading.Event()
53 self.thread = threading.Thread(target=server, args=servargs)
146 @unittest.skipUnless(threading, 'Threading required for this test.')
156 self.serv_evt = threading.Event()
157 self.client_evt = threading.Event(
[all...] |
| /system/bt/service/ipc/ |
| ipc_handler_linux.h | 24 #include <base/threading/thread.h>
|
| /system/tpm/trunks/ |
| trunks_dbus_proxy.h | 23 #include <base/threading/platform_thread.h>
|
| /external/autotest/client/cros/ |
| httpd_unittest.py | 9 import logging, os, sys, threading, urllib, unittest
41 t = threading.Thread(target=_Spam).start()
|
| perf.py | 5 import logging, threading, time
54 threading.Thread(target=self._monitor_performance_state).start()
|
| /external/autotest/server/cros/ |
| remote_command.py | 8 import threading
12 class _HelperThread(threading.Thread):
|
| /external/autotest/site_utils/lxc/container_pool/ |
| async_listener.py | 9 import threading
56 self._thread = threading.Thread(name='connection_listener',
|
| /external/chromium-trace/catapult/devil/devil/android/ |
| device_blacklist.py | 8 import threading
17 self._blacklist_lock = threading.RLock()
|
| /external/tensorflow/tensorflow/contrib/batching/python/ops/ |
| batch_ops_test.py | 21 import threading
55 worker_thread = threading.Thread(target=worker)
96 worker_thread = threading.Thread(target=worker)
130 worker_thread = threading.Thread(target=worker)
181 worker_thread = threading.Thread(target=worker)
201 worker_thread = threading.Thread(target=worker)
236 worker_thread = threading.Thread(target=worker)
267 worker_thread = threading.Thread(target=worker)
|
| /frameworks/base/tests/JankBench/scripts/ |
| adbutil.py | 3 import threading
48 threading.Thread(target=__track_logcat, name=serial + "-waiter", args=(serial, awaited_string, callback)).start()
|
| /kernel/tests/net/test/ |
| leak_test.py | 19 import threading
39 t = threading.Thread(target=ShutdownSocket)
|
