Home
last modified time | relevance | path

Searched refs:threading (Results 1 - 25 of 188) sorted by relevance

12345678

/third_party/python/Lib/test/
H A Dtest_threading.py2 Tests for the threading module.
14 import threading namespace
41 testcase.addCleanup(setattr, threading, 'excepthook', threading.excepthook)
42 threading.excepthook = threading.__excepthook__
56 class TestThread(threading.Thread):
58 threading.Thread.__init__(self, name=name)
104 thread = threading.Thread(name="myname1")
108 thread = threading
[all...]
H A Dtest_threading_local.py12 import threading namespace
39 t = threading.Thread(target=target, args=(local, weaklist))
59 # of a threading.local derived class, the per-thread dictionary
73 with threading_helper.start_threads(threading.Thread(target=f, args=(i,))
83 e1 = threading.Event()
84 e2 = threading.Event()
103 t = threading.Thread(target=f)
130 e1 = threading.Event()
131 e2 = threading.Event()
151 t1 = threading
[all...]
H A Dtest_syslog.py5 import threading namespace
56 start = threading.Event()
72 threads = [threading.Thread(target=opener)]
73 threads += [threading.Thread(target=logger) for k in range(10)]
H A Dtest_threadedtempfile.py21 import threading namespace
30 startEvent = threading.Event()
33 class TempFileGreedy(threading.Thread):
H A Dssl_servers.py5 import threading namespace
120 class HTTPSServerThread(threading.Thread):
128 threading.Thread.__init__(self)
136 threading.Thread.start(self)
157 flag = threading.Event()
H A Dtest_fork1.py8 import threading namespace
24 import_started = threading.Event()
35 t = threading.Thread(target=importer)
H A Dtest_asynchat.py11 import threading namespace
26 class echo_server(threading.Thread):
32 threading.Thread.__init__(self)
99 event = threading.Event()
118 event = threading.Event()
222 s.start_resend_event = threading.Event()
/third_party/python/Lib/multiprocessing/dummy/
H A D__init__.py20 import threading namespace
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
/third_party/python/Lib/test/test_zoneinfo/
H A D_support.py4 import threading namespace
8 OS_ENV_LOCK = threading.Lock()
9 TZPATH_LOCK = threading.Lock()
10 TZPATH_TEST_LOCK = threading.Lock()
15 lock = threading.Lock()
/third_party/python/Lib/test/support/
H A Dthreading_helper.py5 import threading namespace
15 # NOTE: we use thread._count() rather than threading.enumerate() (or the
16 # moral equivalent thereof) because a threading.Thread object is still alive
18 # unregistered from the threading module.
25 return _thread._count(), threading._dangling.copy()
32 values = _thread._count(), threading._dangling
158 Context manager catching threading.Thread exception using
159 threading.excepthook.
168 See threading.excepthook() documentation for these attributes.
201 self._old_hook = threading
[all...]
/third_party/python/Lib/test/test_importlib/
H A Dtest_threaded_import.py14 import threading namespace
39 done_tasks.append(threading.get_ident())
77 self.lock = threading.Lock()
116 done = threading.Event()
131 threading.Thread(target=task, args=(N, done, done_tasks, errors,))
220 t1 = threading.Thread(target=import_ab)
221 t2 = threading.Thread(target=import_ba)
231 import threading
234 t = threading.Thread(target=target)
H A Dthreaded_import_hangers.py10 import threading namespace
21 class Worker(threading.Thread):
23 threading.Thread.__init__(self)
/third_party/python/Lib/
H A Dqueue.py3 import threading namespace
42 self.mutex = threading.Lock()
46 self.not_empty = threading.Condition(self.mutex)
50 self.not_full = threading.Condition(self.mutex)
54 self.all_tasks_done = threading.Condition(self.mutex)
264 # (by using a threading.Semaphore which is itself fair, being based
265 # on threading.Condition), fairness is not part of the API contract.
270 self._count = threading.Semaphore(0)
/third_party/python/Lib/concurrent/futures/
H A Dthread.py11 import threading namespace
21 _global_shutdown_lock = threading.Lock()
37 threading._register_atexit(_python_exit)
151 self._idle_semaphore = threading.Semaphore(0)
155 self._shutdown_lock = threading.Lock()
194 t = threading.Thread(name=thread_name, target=_worker,
/third_party/python/Lib/multiprocessing/
H A Dmanagers.py18 import threading namespace
162 self.mutex = threading.Lock()
168 self.stop_event = threading.Event()
171 accepter = threading.Thread(target=self.accepter)
192 t = threading.Thread(target=self.handle_request, args=(c,))
243 threading.current_thread().name)
300 threading.current_thread().name)
313 threading.current_thread().name)
419 threading.current_thread().name = name
803 if threading
[all...]
H A Dpool.py20 import threading namespace
26 # If threading is available then ThreadPool should be provided. Therefore
226 self._worker_handler = threading.Thread(
238 self._task_handler = threading.Thread(
247 self._result_handler = threading.Thread(
511 thread = threading.current_thread()
529 thread = threading.current_thread()
575 thread = threading.current_thread()
708 if threading.current_thread() is not worker_handler:
719 if threading
[all...]
/third_party/python/Lib/test/test_asyncio/
H A Dtest_runners.py7 import threading namespace
394 assert threading.current_thread() is threading.main_thread()
409 assert threading.current_thread() is threading.main_thread()
427 assert threading.current_thread() is threading.main_thread()
444 assert threading.current_thread() is threading.main_thread()
/third_party/python/Lib/ctypes/test/
H A Dtest_errno.py2 import threading namespace
38 t = threading.Thread(target=_worker)
67 t = threading.Thread(target=_worker)
/third_party/mesa3d/.gitlab-ci/bare-metal/
H A Dserial_buffer.py28 import threading namespace
58 self.read_thread = threading.Thread(
61 self.read_thread = threading.Thread(
65 self.lines_thread = threading.Thread(
/third_party/python/Tools/ccbench/
H A Dccbench.py14 import threading namespace
206 ready_cond = threading.Condition()
207 start_cond = threading.Condition()
222 threads.append(threading.Thread(target=run))
308 start_cond = threading.Condition()
317 ready_cond = threading.Condition()
329 threads.append(threading.Thread(target=run))
440 start_cond = threading.Condition()
449 ready_cond = threading.Condition()
461 threads.append(threading
[all...]
/third_party/python/Lib/asyncio/
H A Dmixins.py3 import threading namespace
6 _global_lock = threading.Lock()
/third_party/python/Lib/test/test_importlib/partial/
H A Dpool_in_threads.py3 import threading namespace
19 threads.append(threading.Thread(target=t))
H A Dcfimport.py3 import threading namespace
29 threads.append(threading.Thread(target=t2 if i % 1 else t1))
/third_party/python/Lib/idlelib/
H A Drpc.py41 import threading namespace
113 print('Thread: %s' % threading.current_thread().name, file=erf)
133 self.sockthread = threading.current_thread()
156 s = self.location + " " + str(threading.current_thread().name)
229 if threading.current_thread() != self.sockthread:
230 cvar = threading.Condition()
239 if threading.current_thread() != self.sockthread:
240 cvar = threading.Condition()
308 if threading.current_thread() is self.sockthread:
/third_party/skia/infra/bots/recipe_modules/flavor/resources/
H A Dios_debug_cmd.py8 import threading namespace
31 logt = threading.Thread(target=collect_log)

Completed in 11 milliseconds

12345678