| /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.assertNotEqual(_thread.get_ident(), 0,
118 self.assertIsInstance(_thread.allocate_lock(), _thread.LockType,
123 self.assertIsInstance(_thread._set_sentinel(), _thread.LockType,
131 _thread.interrupt_main()
[all …]
|
| D | test_threading.py | 12 _thread = import_module('_thread') variable
128 _thread.start_new_thread(f, ())
140 except _thread.error:
152 except _thread.error:
168 tid = _thread.start_new_thread(f, (mutex,))
545 started = _thread.allocate_lock()
546 finish = _thread.allocate_lock()
579 started = _thread.allocate_lock()
580 finish = _thread.allocate_lock()
|
| D | fork_wait.py | 14 _thread = support.import_module('_thread') variable
49 _thread.start_new(self.f, (i,))
|
| D | test_threading_local.py | 8 _thread = support.import_module('_thread') variable
196 _local = _thread._local
210 _threading_local.local = _thread._local
|
| D | test_gdb.py | 16 import _thread
18 _thread = None variable
757 @unittest.skipUnless(_thread,
796 @unittest.skipUnless(_thread,
824 @unittest.skipUnless(_thread,
|
| /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.
11 This module provides a duplicate interface to the :mod:`_thread` module. It is
12 meant to be imported when the :mod:`_thread` module is not provided on a
18 import _thread
20 import _dummy_thread as _thread
|
| D | _thread.rst | 1 :mod:`_thread` --- Low-level threading API
4 .. module:: _thread
28 implementation. For systems lacking the :mod:`_thread` module, the
163 import _thread
165 a_lock = _thread.allocate_lock()
179 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/autotest/site_utils/lxc/container_pool/ |
| D | async_listener.py | 43 self._thread = None
56 self._thread = threading.Thread(name='connection_listener',
58 self._thread.start()
101 self._thread.join(1)
102 return not self._thread.isAlive()
|
| /external/mesa3d/src/glx/apple/ |
| D | apple_glx_log.c | 116 char *_thread; in _apple_glx_vlog() local
117 asprintf(&_thread, "%"PRIu64, thread); in _apple_glx_vlog()
118 if (_thread) { in _apple_glx_vlog()
119 asl_set(msg, "Thread", _thread); in _apple_glx_vlog()
120 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(
166 self._thread.daemon = True
169 self._thread.start()
181 self._thread, Queue._finalize_join,
182 [weakref.ref(self._thread)],
298 if self._thread is None:
|
| /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)],
319 if self._thread is None:
|
| /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/python/cpython3/Lib/ |
| D | threading.py | 4 import _thread
32 _start_new_thread = _thread.start_new_thread
33 _allocate_lock = _thread.allocate_lock
34 _set_sentinel = _thread._set_sentinel
35 get_ident = _thread.get_ident
36 ThreadError = _thread.error
38 _CRLock = _thread.RLock
41 TIMEOUT_MAX = _thread.TIMEOUT_MAX
42 del _thread
1271 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 | 82 self._thread = threading.Thread(target=self._server.serve_forever)
86 self._thread.start()
91 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/skia/infra/bots/recipe_modules/core/resources/ |
| D | elf_symbolizer.py | 244 self._thread = None # Threading.thread instance.
409 self._thread = threading.Thread(
412 self._thread.daemon = True # Don't prevent early process exit.
413 self._thread.start()
|
| /external/skqp/infra/bots/recipe_modules/core/resources/ |
| D | elf_symbolizer.py | 244 self._thread = None # Threading.thread instance.
409 self._thread = threading.Thread(
412 self._thread.daemon = True # Don't prevent early process exit.
413 self._thread.start()
|
| /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/cpython3/Lib/importlib/ |
| D | _bootstrap.py | 58 self.lock = _thread.allocate_lock()
59 self.wakeup = _thread.allocate_lock()
67 me = _thread.get_ident()
83 tid = _thread.get_ident()
103 tid = _thread.get_ident()
169 if _thread is None:
|