| /external/python/cpython3/Lib/test/ |
| D | test_threading.py | 15 import threading
63 testcase.addCleanup(setattr, threading, 'excepthook', threading.excepthook)
64 threading.excepthook = threading.__excepthook__
78 class TestThread(threading.Thread):
80 threading.Thread.__init__(self, name=name)
127 thread = threading.Thread(name="myname1")
131 thread = threading.Thread(name=123)
135 thread = threading.Thread(target=func, name="myname2")
138 with mock.patch.object(threading, '_counter', return_value=2):
139 thread = threading.Thread(name="")
[all …]
|
| D | test_threading_local.py | 11 import threading
38 t = threading.Thread(target=target, args=(local, weaklist))
72 with threading_helper.start_threads(threading.Thread(target=f, args=(i,))
82 e1 = threading.Event()
83 e2 = threading.Event()
102 t = threading.Thread(target=f)
129 e1 = threading.Event()
130 e2 = threading.Event()
150 t1 = threading.Thread(target=f1)
153 t2 = threading.Thread(target=f2)
[all …]
|
| /external/tensorflow/tensorflow/python/training/ |
| D | coordinator_test.py | 18 import threading
56 coord.register_thread(threading.current_thread())
82 wait_for_stop_ev = threading.Event()
83 has_stopped_ev = threading.Event()
84 t = threading.Thread(
97 threading.Thread(target=SleepABit, args=(0.01,)),
98 threading.Thread(target=SleepABit, args=(0.02,)),
99 threading.Thread(target=SleepABit, args=(0.01,))
110 threading.Thread(target=SleepABit, args=(0.01, coord)),
111 threading.Thread(target=SleepABit, args=(0.02, coord)),
[all …]
|
| /external/libcxx/docs/DesignDocs/ |
| D | ThreadingSupportAPI.rst | 11 Libc++ supports using multiple different threading models and configurations
12 to implement the threading parts of libc++, including ``<thread>`` and ``<mutex>``.
14 other. To address this libc++ wraps the underlying threading API in a new and
15 consistent API, which it uses internally to implement threading primitives.
18 threading interface. It contains forward declarations of the internal threading
24 In order to support vendors with custom threading API's libc++ allows the
25 entire internal threading interface to be provided by an external,
36 libc++ can be compiled with its internal threading API delegating to an external
39 expected to provide the implementation of the libc++ internal threading API.
42 ``<__external_threading>`` header, which declares the libc++ internal threading
[all …]
|
| /external/cronet/tot/third_party/libc++/src/docs/DesignDocs/ |
| D | ThreadingSupportAPI.rst | 11 Libc++ supports using multiple different threading models and configurations
12 to implement the threading parts of libc++, including ``<thread>`` and ``<mutex>``.
14 other. To address this libc++ wraps the underlying threading API in a new and
15 consistent API, which it uses internally to implement threading primitives.
18 threading interface. It documents the functions and declarations required
19 to fullfil the internal threading interface.
24 In order to support vendors with custom threading API's libc++ allows the
25 entire internal threading interface to be provided by an external,
36 libc++ can be compiled with its internal threading API delegating to an external
39 expected to provide the implementation of the libc++ internal threading API.
[all …]
|
| /external/cronet/stable/third_party/libc++/src/docs/DesignDocs/ |
| D | ThreadingSupportAPI.rst | 11 Libc++ supports using multiple different threading models and configurations
12 to implement the threading parts of libc++, including ``<thread>`` and ``<mutex>``.
14 other. To address this libc++ wraps the underlying threading API in a new and
15 consistent API, which it uses internally to implement threading primitives.
18 threading interface. It documents the functions and declarations required
19 to fullfil the internal threading interface.
24 In order to support vendors with custom threading API's libc++ allows the
25 entire internal threading interface to be provided by an external,
36 libc++ can be compiled with its internal threading API delegating to an external
39 expected to provide the implementation of the libc++ internal threading API.
[all …]
|
| /external/sdv/vsomeip/third_party/boost/config/test/link/test/ |
| D | Jamfile.v2 | 65 project : requirements -<threading>multi <hardcode-dll-paths>false ;
76 …uild>no <toolset>msvc-12.0:<build>no <link>static <runtime-link>static <threading>single debug : l…
79 …uild>no <toolset>msvc-12.0:<build>no <link>static <runtime-link>static <threading>single release :…
82 : : : <link>static <runtime-link>static <threading>multi debug : link_test_smd ;
85 : : : <link>static <runtime-link>static <threading>multi release : link_test_smr ;
88 : : : <link>static <runtime-link>shared <threading>multi debug : link_test_dmd ;
91 : : : <link>static <runtime-link>shared <threading>multi release : link_test_dmr ;
94 : : : <link>static <runtime-link>shared <threading>single debug : link_test_dsd ;
97 : : : <link>static <runtime-link>shared <threading>single release : link_test_dsr ;
100 …: : : <define>BOOST_DYN_LINK=1 <link>shared <runtime-link>shared <threading>multi debug : link_tes…
[all …]
|
| /external/scapy/test/contrib/automotive/gm/ |
| D | gmlanutils.uts | 38 started = threading.Event()
52 thread = threading.Thread(target=ecusim)
64 started = threading.Event()
70 thread = threading.Thread(target=ecusim)
83 started = threading.Event()
92 thread = threading.Thread(target=ecusim)
103 started = threading.Event()
114 thread = threading.Thread(target=ecusim)
129 started = threading.Event()
137 thread = threading.Thread(target=ecusim)
[all …]
|
| /external/libchrome/libchrome_tools/patch/ |
| D | ThreadLocalStorage-Add-a-function-to-destroy-pthread.patch | 17 base/threading/thread_local_storage.cc | 11 +++++++++++
18 base/threading/thread_local_storage.h | 7 +++++++
21 diff --git a/base/threading/thread_local_storage.cc b/base/threading/thread_local_storage.cc
23 --- a/base/threading/thread_local_storage.cc
24 +++ b/base/threading/thread_local_storage.cc
43 diff --git a/base/threading/thread_local_storage.h b/base/threading/thread_local_storage.h
45 --- a/base/threading/thread_local_storage.h
46 +++ b/base/threading/thread_local_storage.h
|
| /external/libcxx/utils/google-benchmark/ |
| D | mingw.py | 80 threading = arch.setdefault(value[2].strip(), {})
81 exceptions = threading.setdefault(value[3].strip(), {})
172 def root(location = None, arch = None, version = None, threading = None, argument
180 if not (arch and version and threading and exceptions and revision):
191 if not threading:
194 threading = 'posix'
196 threading = 'win32'
198 threading = keys[0]
200 keys = versions[version][arch][threading].keys()
208 revision = max(versions[version][arch][threading][exceptions].keys())
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _server_wait_for_termination_test.py | 19 import threading
38 termination_event = threading.Event()
41 wait_thread = threading.Thread(
57 termination_event = threading.Event()
60 wait_thread = threading.Thread(
77 termination_event = threading.Event()
80 wait_thread = threading.Thread(
|
| /external/python/watchdog/src/watchdog/utils/ |
| D | __init__.py | 18 import threading
35 class BaseThread(threading.Thread):
39 threading.Thread.__init__(self)
44 self._stopped_event = threading.Event()
47 def stopped_event(self) -> threading.Event:
76 threading.Thread.start(self)
|
| /external/autotest/server/cros/ |
| D | stress_unittest.py | 5 import threading
29 event = threading.Event()
45 event = threading.Event()
59 event = threading.Event()
70 event = threading.Event()
89 start_event = threading.Event()
90 ran_event = threading.Event()
|
| D | lockfile.py | 58 import threading
64 if not hasattr(threading, "current_thread"):
65 threading.current_thread = threading.currentThread
66 if not hasattr(threading.Thread, "get_name"):
67 threading.Thread.get_name = threading.Thread.getName
145 name = threading.current_thread().get_name()
|
| /external/python/cpython3/Lib/multiprocessing/dummy/ |
| D | __init__.py | 20 import threading
26 from threading import Lock, RLock, Semaphore, BoundedSemaphore
27 from threading import Event, Condition, Barrier
34 class DummyProcess(threading.Thread):
37 threading.Thread.__init__(self, group, target, name, args, kwargs)
51 threading.Thread.start(self)
65 current_process = threading.current_thread
|
| /external/python/cpython3/Doc/deprecations/ |
| D | pending-removal-in-future.rst | 112 * :mod:`threading` methods:
114 * :meth:`!threading.Condition.notifyAll`: use :meth:`~threading.Condition.notify_all`.
115 * :meth:`!threading.Event.isSet`: use :meth:`~threading.Event.is_set`.
116 * :meth:`!threading.Thread.isDaemon`, :meth:`threading.Thread.setDaemon`:
117 use :attr:`threading.Thread.daemon` attribute.
118 * :meth:`!threading.Thread.getName`, :meth:`threading.Thread.setName`:
119 use :attr:`threading.Thread.name` attribute.
120 * :meth:`!threading.currentThread`: use :meth:`threading.current_thread`.
121 * :meth:`!threading.activeCount`: use :meth:`threading.active_count`.
|
| /external/python/cpython3/Lib/test/test_zoneinfo/ |
| D | _support.py | 4 import threading
8 OS_ENV_LOCK = threading.Lock()
9 TZPATH_LOCK = threading.Lock()
10 TZPATH_TEST_LOCK = threading.Lock()
15 lock = threading.Lock()
|
| /external/autotest/client/cros/bluetooth/floss/ |
| D | utils.py | 14 import threading
67 threading.current_thread().name, str(method))
103 current_thread_name = threading.current_thread().name
108 done_event = threading.Event()
120 threading.current_thread().name, str(method))
143 current_thread_name = threading.current_thread().name
|
| /external/cronet/tot/build/android/pylib/utils/ |
| D | instrumentation_tracing.py | 23 import threading
137 thread_id = threading.current_thread().ident
140 thread_name = threading.current_thread().name
176 threading.settrace(None)
180 threading.settrace(trace_func)
190 threading.settrace(traceFunc)
197 threading.settrace(None)
|
| /external/angle/build/android/pylib/utils/ |
| D | instrumentation_tracing.py | 23 import threading
137 thread_id = threading.current_thread().ident
140 thread_name = threading.current_thread().name
176 threading.settrace(None)
180 threading.settrace(trace_func)
190 threading.settrace(traceFunc)
197 threading.settrace(None)
|
| /external/cronet/stable/build/android/pylib/utils/ |
| D | instrumentation_tracing.py | 23 import threading
137 thread_id = threading.current_thread().ident
140 thread_name = threading.current_thread().name
176 threading.settrace(None)
180 threading.settrace(trace_func)
190 threading.settrace(traceFunc)
197 threading.settrace(None)
|
| /external/python/cpython3/Lib/_pyrepl/ |
| D | _threading_handler.py | 9 from threading import Thread
31 import threading
35 lock: threading.Lock = field(default_factory=threading.Lock)
74 threading.excepthook = handler.exception
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/infrastructure/k8s_internal/ |
| D | k8s_log_collector.py | 17 import threading
26 class PodLogCollector(threading.Thread):
30 stop_event: threading.Event
31 drain_event: threading.Event
45 stop_event: threading.Event,
56 self.drain_event = threading.Event()
|
| /external/python/cpython3/Lib/test/test_free_threading/ |
| D | test_gc.py | 3 import threading
4 from threading import Thread
18 event = threading.Event()
38 event = threading.Event()
|
| /external/tensorflow/tensorflow/python/summary/writer/ |
| D | event_file_writer.py | 20 import threading
69 self._flush_complete = threading.Event()
166 class _EventLoggerThread(threading.Thread):
188 threading.Thread.__init__(self, name="EventLoggerThread")
243 self._mutex = threading.Lock()
246 self._not_empty = threading.Condition(self._mutex)
249 self._not_full = threading.Condition(self._mutex)
|