| /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 …]
|
| D | test_contextlib.py | 9 import threading
11 threading = None variable
278 @unittest.skipUnless(threading, 'Threading required for this test.')
293 lock = threading.Lock()
297 lock = threading.RLock()
301 lock = threading.Condition()
307 lock = threading.Semaphore()
317 lock = threading.BoundedSemaphore()
|
| D | test_asynchat.py | 12 import threading
14 threading = None variable
19 if threading:
20 class echo_server(threading.Thread):
26 threading.Thread.__init__(self)
94 event = threading.Event()
103 @unittest.skipUnless(threading, 'Threading required for this test.')
114 event = threading.Event()
218 s.start_resend_event = threading.Event()
|
| D | threaded_import_hangers.py | 10 import threading
21 class Worker(threading.Thread):
23 threading.Thread.__init__(self)
|
| /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/autotest/site_utils/rpm_control_system/ |
| D | test_client.py | 5 import threading
24 threading.Thread(target=queue_request,
26 threading.Thread(target=queue_request,
28 threading.Thread(target=queue_request,
30 threading.Thread(target=queue_request,
32 threading.Thread(target=queue_request,
|
| 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/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/libchrome/base/ |
| D | base.gypi | 681 'threading/non_thread_safe.h',
682 'threading/non_thread_safe_impl.cc',
683 'threading/non_thread_safe_impl.h',
684 'threading/platform_thread.h',
685 'threading/platform_thread_android.cc',
686 'threading/platform_thread_internal_posix.cc',
687 'threading/platform_thread_internal_posix.h',
688 'threading/platform_thread_linux.cc',
689 'threading/platform_thread_mac.mm',
690 'threading/platform_thread_posix.cc',
[all …]
|
| /external/autotest/server/cros/ |
| 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/libchrome/ |
| D | Android.bp | 193 "base/threading/non_thread_safe_impl.cc",
194 "base/threading/platform_thread_posix.cc",
195 "base/threading/post_task_and_reply_impl.cc",
196 "base/threading/sequenced_task_runner_handle.cc",
197 "base/threading/sequenced_worker_pool.cc",
198 "base/threading/simple_thread.cc",
199 "base/threading/thread.cc",
200 "base/threading/thread_checker_impl.cc",
201 "base/threading/thread_collision_warner.cc",
202 "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/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/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/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/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/python/cpython2/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 as _threading
|
| /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/parameter-framework/upstream/tools/clientSimulator/clientsimulator/testGenerator/ |
| D | SubprocessLogger.py | 29 import threading
36 class StreamLoggerThread(threading.Thread):
84 class SubprocessLoggerThread(threading.Thread):
89 __closeEvent = threading.Event()
205 return [t for t in threading.enumerate() if isinstance(t, cls)]
|
| /external/toolchain-utils/crb/ |
| D | machine_manager_singleton.py | 4 import threading
32 _lock = threading.RLock()
35 image_lock = threading.Lock()
94 m.autotest_run = threading.current_thread()
99 m.autotest_run = threading.current_thread()
104 m.autotest_run = threading.current_thread()
|