/external/python/cpython3/Lib/test/ |
D | test_dummy_thread.py | 1 import _dummy_thread as _thread namespace 17 self.lock = _thread.allocate_lock() 32 with _thread.LockType(): 74 _thread.start_new_thread(delay_unlock,(self.lock, DELAY)) 109 self.assertRaises(SystemExit, _thread.exit) 112 self.assertIsInstance(_thread.get_ident(), int, 114 self.assertGreater(_thread.get_ident(), 0) 117 self.assertIsInstance(_thread.allocate_lock(), _thread.LockType, 122 self.assertIsInstance(_thread._set_sentinel(), _thread.LockType, 130 _thread.interrupt_main() [all …]
|
D | test_threading.py | 12 import _thread 128 tid = _thread.start_new_thread(f, ()) 140 except _thread.error: 152 except _thread.error: 169 tid = _thread.start_new_thread(f, (mutex,)) 582 started = _thread.allocate_lock() 583 finish = _thread.allocate_lock() 617 started = _thread.allocate_lock() 618 finish = _thread.allocate_lock()
|
D | test_threading_local.py | 9 import _thread 197 _local = _thread._local 211 _threading_local.local = _thread._local
|
/external/python/cpython2/Lib/test/ |
D | test_dummy_thread.py | 8 import dummy_thread as _thread namespace 23 self.lock = _thread.allocate_lock() 39 self.assertRaises(_thread.error, self.lock.release) 74 _thread.start_new_thread(delay_unlock,(self.lock, DELAY)) 91 self.assertRaises(SystemExit, _thread.exit) 95 self.assertIsInstance(_thread.get_ident(), int, 97 self.assertNotEqual(_thread.get_ident(), 0, 102 self.assertIsInstance(_thread.allocate_lock(), _thread.LockType, 110 _thread.interrupt_main() 111 self.assertRaises(KeyboardInterrupt, _thread.start_new_thread, [all …]
|
/external/python/cpython3/Doc/library/ |
D | _dummy_thread.rst | 1 :mod:`_dummy_thread` --- Drop-in replacement for the :mod:`_thread` module 5 :synopsis: Drop-in replacement for the _thread module. 10 Python now always has threading enabled. Please use :mod:`_thread` 15 This module provides a duplicate interface to the :mod:`_thread` module. 16 It was meant to be imported when the :mod:`_thread` module was not provided
|
D | _thread.rst | 1 :mod:`_thread` --- Low-level threading API 4 .. module:: _thread 160 import _thread 162 a_lock = _thread.allocate_lock() 176 equivalent to calling :func:`_thread.exit`.
|
/external/autotest/server/cros/ |
D | remote_command.py | 61 self._thread = _HelperThread(self._host, cmd) 62 self._thread.start() 85 self._thread.join(timeout) 86 if self._thread.isAlive(): 107 return self._thread.result
|
/external/mesa3d/src/glx/apple/ |
D | apple_glx_log.c | 117 char *_thread; in _apple_glx_vlog() local 118 asprintf(&_thread, "%"PRIu64, thread); in _apple_glx_vlog() 119 if (_thread) { in _apple_glx_vlog() 120 asl_set(msg, "Thread", _thread); in _apple_glx_vlog() 121 free(_thread); in _apple_glx_vlog()
|
/external/python/cpython3/Lib/multiprocessing/ |
D | resource_sharer.py | 70 self._thread = None 100 self._thread.join(timeout) 101 if self._thread.is_alive(): 105 self._thread = None 124 self._thread = None 135 self._thread = t
|
D | queues.py | 71 self._thread = None 86 if self._thread is None: 160 self._thread = threading.Thread( 167 self._thread.daemon = True 170 self._thread.start() 175 self._thread, Queue._finalize_join, 176 [weakref.ref(self._thread)], 306 if self._thread is None:
|
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
D | fork_windows.pyx.pxi | 26 self._thread = threading.Thread(target=target, args=args) 29 self._thread.daemon = daemonic 32 self._thread.start() 35 self._thread.join()
|
D | fork_posix.pyx.pxi | 97 self._thread = threading.Thread(target=managed_target, args=args) 99 self._thread = threading.Thread(target=target, args=args) 102 self._thread.daemon = daemonic 107 self._thread.start() 110 self._thread.join()
|
/external/python/cpython2/Lib/multiprocessing/ |
D | queues.py | 90 self._thread = None 106 if self._thread is None: 186 self._thread = threading.Thread( 192 self._thread.daemon = True 195 self._thread.start() 201 self._thread, Queue._finalize_join, 202 [weakref.ref(self._thread)], 317 if self._thread is None:
|
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
D | test_utilities.py | 33 self._thread = threading.Thread(target=wrapped_function) 34 self._thread.start() 41 self._thread.join()
|
/external/autotest/client/cros/ |
D | device_jail_utils.py | 46 self._thread = threading.Thread(target=target_func) 51 self._thread.start() 54 self._thread.join(self._timeout_func()) 55 if self._thread.is_alive() and not exc_val:
|
/external/autotest/client/site_tests/platform_PrinterPpds/ |
D | fake_printer.py | 50 self._thread = threading.Thread(target = self._thread_read_docs) 51 self._thread.start(); 72 self._thread.join()
|
D | test_multithreaded_processor.py | 31 return self._processor.run(self._thread, count) 33 def _thread(self, task_id): member in EvenNumbersGenerator
|
D | multithreaded_processor.py | 64 thread = threading.Thread(target=self._thread, args=[function_task]) 82 def _thread(self, function_task): member in MultithreadedProcessor
|
/external/python/cpython3/Lib/ |
D | threading.py | 5 import _thread 33 _start_new_thread = _thread.start_new_thread 34 _allocate_lock = _thread.allocate_lock 35 _set_sentinel = _thread._set_sentinel 36 get_ident = _thread.get_ident 37 ThreadError = _thread.error 39 _CRLock = _thread.RLock 42 TIMEOUT_MAX = _thread.TIMEOUT_MAX 43 del _thread 1255 from _thread import stack_size [all …]
|
/external/autotest/client/cros/audio/ |
D | cmd_utils.py | 61 self._thread = threading.Thread(target=self._service_run) 62 self._thread.daemon = True 63 self._thread.start() 112 self._thread.join()
|
/external/autotest/client/site_tests/policy_ProxySettings/ |
D | policy_ProxySettings.py | 83 self._thread = threading.Thread(target=self._server.serve_forever) 87 self._thread.start() 92 self._thread.join()
|
/external/webrtc/webrtc/test/channel_transport/ |
D | udp_socket_manager_posix.cc | 188 : _thread(UdpSocketManagerPosixImpl::Run, in UdpSocketManagerPosixImpl() 224 _thread.Start(); in Start() 225 _thread.SetPriority(rtc::kRealtimePriority); in Start() 233 _thread.Stop(); in Stop()
|
/external/webrtc/webrtc/voice_engine/test/android/android_test/jni/ |
D | android_test.cc | 180 rtc::PlatformThread _thread; member in ThreadTest 185 if (_thread) in ~ThreadTest() 186 _thread->Stop(); in ~ThreadTest() 191 _thread(Run, this, "ThreadTest thread"); in ThreadTest() 264 _thread->Stop(); in Process() 273 if (_thread) in RunTest() 275 _thread->Start(); in RunTest()
|
/external/python/cpython2/Doc/library/ |
D | dummy_thread.rst | 24 import thread as _thread 26 import dummy_thread as _thread
|
/external/autotest/client/site_tests/network_ProxyResolver/ |
D | network_ProxyResolver.py | 84 self._thread = threading.Thread(target=self._server.serve_forever) 88 self._thread.start() 94 self._thread.join()
|