| /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/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | DefaultExecutor.kt | 31 private var _thread: Thread? = null variable
34 get() = _thread ?: createThreadSync()
86 _thread = null // this thread is dead in invokeOnTimeout()
96 return _thread ?: Thread(this, THREAD_NAME).apply { in createThreadSync()
97 _thread = this in createThreadSync()
106 assert { _thread == null } // ensure we are at a clean state in ensureStarted()
127 while (debugStatus != SHUTDOWN_ACK && _thread != null) { in shutdown()
128 _thread?.let { unpark(it) } // wake up thread if present in shutdown()
146 get() = _thread != null
|
| /external/pigweed/pw_env_setup/py/pw_env_setup/ |
| D | spinner.py | 29 self._thread = None
49 self._thread = threading.Thread(target=self._spin)
50 self._thread.start()
56 assert self._thread
58 self._thread.join()
59 self._thread = None
|
| /external/llvm-project/debuginfo-tests/dexter/dex/debugger/lldb/ |
| D | LLDB.py | 28 self._thread = None
156 self._thread = self._process.GetThreadAtIndex(0)
157 assert self._thread, (self._process, self._thread)
160 self._thread.StepInto()
170 for i in range(0, self._thread.GetNumFrames()):
171 sb_frame = self._thread.GetFrameAtIndex(i)
214 reason = self._translate_stop_reason(self._thread.GetStopReason())
227 return not self._thread.GetFrameAtIndex(0)
234 result = self._thread.GetFrameAtIndex(frame_idx
269 var_result = self._thread.GetFrameAtIndex(frame_idx).FindVariable(expression)
|
| /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 | 118 char *_thread; in _apple_glx_vlog() local
119 asprintf(&_thread, "%"PRIu64, thread); in _apple_glx_vlog()
120 if (_thread) { in _apple_glx_vlog()
121 asl_set(msg, "Thread", _thread); in _apple_glx_vlog()
122 free(_thread); in _apple_glx_vlog()
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | resource_sharer.py | 69 self._thread = None
99 self._thread.join(timeout)
100 if self._thread.is_alive():
104 self._thread = None
120 self._thread = None
131 self._thread = t
|
| D | queues.py | 77 self._thread = None
93 if self._thread is None:
169 self._thread = threading.Thread(
176 self._thread.daemon = True
179 self._thread.start()
184 self._thread, Queue._finalize_join,
185 [weakref.ref(self._thread)],
316 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/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/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/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
34 _start_new_thread = _thread.start_new_thread
35 _allocate_lock = _thread.allocate_lock
36 _set_sentinel = _thread._set_sentinel
37 get_ident = _thread.get_ident
39 get_native_id = _thread.get_native_id
44 ThreadError = _thread.error
46 _CRLock = _thread.RLock
49 TIMEOUT_MAX = _thread.TIMEOUT_MAX
50 del _thread
[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/python/cpython3/Lib/test/ |
| D | test_threading.py | 11 import _thread
134 tid = _thread.start_new_thread(f, ())
146 except _thread.error:
158 except _thread.error:
175 tid = _thread.start_new_thread(f, (mutex,))
649 started = _thread.allocate_lock()
650 finish = _thread.allocate_lock()
684 started = _thread.allocate_lock()
685 finish = _thread.allocate_lock()
1405 _thread.interrupt_main()
[all …]
|
| D | test_threading_local.py | 9 import _thread
197 _local = _thread._local
211 _threading_local.local = _thread._local
|
| /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/python/cpython2/Doc/library/ |
| D | dummy_thread.rst | 24 import thread as _thread
26 import dummy_thread as _thread
|
| /external/llvm-project/lldb/test/API/functionalities/gdb_remote_client/ |
| D | gdbclientutils.py | 312 _thread = None variable in MockGDBServer
330 self._thread = threading.Thread(target=self._run)
331 self._thread.start()
335 self._thread.join()
336 self._thread = None
|
| /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()
|
| /external/python/cffi/cffi/ |
| D | lock.py | 10 from _thread import allocate_lock
|
| /external/python/cpython3/Doc/library/ |
| D | _thread.rst | 1 :mod:`_thread` --- Low-level threading API
4 .. module:: _thread
186 import _thread
188 a_lock = _thread.allocate_lock()
202 equivalent to calling :func:`_thread.exit`.
|