| /external/python/cpython3/Lib/test/ |
| D | test_threading.py | 13 threading = import_module('threading') variable
43 class TestThread(threading.Thread):
45 threading.Thread.__init__(self, name=name)
95 sema = threading.BoundedSemaphore(value=3)
96 mutex = threading.RLock()
122 self.assertIsNotNone(threading.currentThread().ident)
124 ident.append(threading.currentThread().ident)
126 done = threading.Event()
132 del threading._active[ident[0]]
139 threading.stack_size(262144)
[all …]
|
| D | test_threading_local.py | 9 threading = support.import_module('threading') variable
33 t = threading.Thread(target=target, args=(local, weaklist))
67 with support.start_threads(threading.Thread(target=f, args=(i,))
77 e1 = threading.Event()
78 e2 = threading.Event()
97 t = threading.Thread(target=f)
124 e1 = threading.Event()
125 e2 = threading.Event()
145 t1 = threading.Thread(target=f1)
148 t2 = threading.Thread(target=f2)
|
| /external/tensorflow/tensorflow/python/training/ |
| D | coordinator_test.py | 22 import threading
60 coord.register_thread(threading.current_thread())
86 wait_for_stop_ev = threading.Event()
87 has_stopped_ev = threading.Event()
88 t = threading.Thread(
101 threading.Thread(target=SleepABit, args=(0.01,)),
102 threading.Thread(target=SleepABit, args=(0.02,)),
103 threading.Thread(target=SleepABit, args=(0.01,))
114 threading.Thread(target=SleepABit, args=(0.01, coord)),
115 threading.Thread(target=SleepABit, args=(0.02, coord)),
[all …]
|
| /external/python/cpython2/Lib/test/ |
| D | test_threading.py | 11 threading = test.test_support.import_module('threading') variable
35 class TestThread(threading.Thread):
37 threading.Thread.__init__(self, name=name)
86 sema = threading.BoundedSemaphore(value=3)
87 mutex = threading.RLock()
113 self.assertIsNotNone(threading.currentThread().ident)
115 ident.append(threading.currentThread().ident)
117 done = threading.Event()
123 del threading._active[ident[0]]
130 threading.stack_size(262144)
[all …]
|
| D | test_capi.py | 12 import threading
15 threading = None variable
25 @unittest.skipUnless(threading, 'Threading required for this test.')
72 context.lock = threading.Lock()
73 context.event = threading.Event()
75 threads = [threading.Thread(target=self.pendingcalls_thread,
104 @unittest.skipUnless(threading and thread, 'Threading required for this test.')
124 t = threading.Thread(target=target)
|
| D | test_nntplib.py | 7 import threading
9 threading = None variable
37 self.evt = threading.Event()
41 threading.Thread(
50 @unittest.skipUnless(threading, 'threading required')
59 @unittest.skipUnless(threading, 'threading required')
|
| D | test_threading_local.py | 9 threading = support.import_module('threading') variable
32 t = threading.Thread(target=target, args=(local, weaklist))
66 with support.start_threads(threading.Thread(target=f, args=(i,))
76 e1 = threading.Event()
77 e2 = threading.Event()
95 t = threading.Thread(target=f)
126 e1 = threading.Event()
127 e2 = threading.Event()
147 t1 = threading.Thread(target=f1)
150 t2 = threading.Thread(target=f2)
|
| D | 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()
163 self.thread = threading.Thread(target=debugging_server, args=serv_args)
265 @unittest.skipUnless(threading, 'Threading required for this test.')
[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/python/cpython2/Lib/multiprocessing/dummy/ |
| D | __init__.py | 45 import threading
53 from threading import Lock, RLock, Semaphore, BoundedSemaphore
54 from threading import Event
61 class DummyProcess(threading.Thread):
64 threading.Thread.__init__(self, group, target, name, args, kwargs)
75 threading.Thread.start(self)
88 class Condition(threading._Condition):
89 notify_all = threading._Condition.notify_all.im_func
96 current_process = threading.current_thread
|
| /external/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/autotest/server/cros/ |
| D | lockfile.py | 55 import threading
60 if not hasattr(threading, "current_thread"):
61 threading.current_thread = threading.currentThread
62 if not hasattr(threading.Thread, "get_name"):
63 threading.Thread.get_name = threading.Thread.getName
141 name = threading.current_thread().get_name()
|
| D | stress_unittest.py | 5 import threading
27 event = threading.Event()
43 event = threading.Event()
57 event = threading.Event()
68 event = threading.Event()
87 start_event = threading.Event()
88 ran_event = threading.Event()
|
| /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)
48 threading.Thread.start(self)
62 current_process = threading.current_thread
|
| /external/ltp/testcases/kernel/io/disktest/ |
| D | Makefile.aix | 139 ALLHDRS=main.h sfunc.h parse.h childmain.h threading.h globals.h usage.h Getopt.h io.h dump.h timer…
140 SRCS=main.c sfunc.c parse.c childmain.c threading.c globals.c usage.c Getopt.c io.c dump.c timer.c …
141 OBJS=main.o sfunc.o parse.o childmain.o threading.o globals.o usage.o Getopt.o io.o dump.o timer.o …
153 childmain.o: childmain.c childmain.h sfunc.h parse.h threading.h $(GBLHDRS)
154 threading.o: threading.c threading.h childmain.h sfunc.h $(GBLHDRS)
155 globals.o: globals.c threading.h $(GBLHDRS)
|
| /external/libchrome/ |
| D | Android.bp | 214 "base/threading/non_thread_safe_impl.cc",
215 "base/threading/platform_thread_posix.cc",
216 "base/threading/post_task_and_reply_impl.cc",
217 "base/threading/sequenced_task_runner_handle.cc",
218 "base/threading/sequenced_worker_pool.cc",
219 "base/threading/simple_thread.cc",
220 "base/threading/thread.cc",
221 "base/threading/thread_checker_impl.cc",
222 "base/threading/thread_collision_warner.cc",
223 "base/threading/thread_id_name_manager.cc",
[all …]
|
| D | SConstruct | 167 threading/non_thread_safe_impl.cc
168 threading/platform_thread_internal_posix.cc
169 threading/platform_thread_linux.cc
170 threading/platform_thread_posix.cc
171 threading/post_task_and_reply_impl.cc
172 threading/sequenced_task_runner_handle.cc
173 threading/sequenced_worker_pool.cc
174 threading/simple_thread.cc
175 threading/thread.cc
176 threading/thread_checker_impl.cc
[all …]
|
| /external/autotest/site_utils/rpm_control_system/ |
| D | rpm_integration_test.py | 2 import threading
57 threading.Thread(target=rpm.queue_request,
59 threading.Thread(target=rpm.queue_request,
78 threading.Thread(target=rpm.queue_request,
80 threading.Thread(target=rpm.queue_request,
131 threading.Thread(target=poe_controller.queue_request,
133 threading.Thread(target=poe_controller.queue_request,
|
| /external/python/cpython3/Doc/library/ |
| D | dummy_threading.rst | 1 :mod:`dummy_threading` --- Drop-in replacement for the :mod:`threading` module
5 :synopsis: Drop-in replacement for the threading module.
11 This module provides a duplicate interface to the :mod:`threading` module. It
18 import threading
20 import dummy_threading as threading
|
| /external/python/cpython2/Doc/includes/ |
| D | mp_benchmarks.py | 8 import time, sys, multiprocessing, threading, Queue, gc
188 test_queuespeed(threading.Thread, Queue.Queue(),
189 threading.Condition())
213 test_lockspeed(threading.Lock())
215 test_lockspeed(threading.RLock())
228 test_conditionspeed(threading.Thread, threading.Condition())
|
| /external/python/cpython2/Lib/ctypes/test/ |
| D | test_errno.py | 6 import threading
8 threading = None variable
29 if threading:
42 t = threading.Thread(target=_worker)
71 t = threading.Thread(target=_worker)
|
| /external/python/cpython3/Lib/ctypes/test/ |
| D | test_errno.py | 5 import threading
7 threading = None variable
28 if threading:
41 t = threading.Thread(target=_worker)
70 t = threading.Thread(target=_worker)
|
| /external/autotest/site_utils/ |
| D | metadata_reporter.py | 15 import threading
42 _report_lock = threading.Lock()
43 _abort = threading.Event()
44 _queue_full = threading.Event()
146 reporting_thread = threading.Thread(target=_run)
|
| /external/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/ |
| D | log.py | 9 import threading
16 _lock = threading.Lock()
23 _tls = threading.local() # tls used to detect forking/etc
87 tid = threading.current_thread().ident
91 "pid": os.getpid(), "tid": threading.current_thread().ident,
155 tid = threading.current_thread().ident
|
| /external/python/cpython3/Lib/ |
| D | queue.py | 4 import threading
6 import dummy_threading as threading namespace
35 self.mutex = threading.Lock()
39 self.not_empty = threading.Condition(self.mutex)
43 self.not_full = threading.Condition(self.mutex)
47 self.all_tasks_done = threading.Condition(self.mutex)
|