Home
last modified time | relevance | path

Searched refs:threading (Results 1 – 25 of 411) sorted by relevance

12345678910>>...17

/third_party/python/Lib/test/
Dtest_threading.py14 import threading
40 testcase.addCleanup(setattr, threading, 'excepthook', threading.excepthook)
41 threading.excepthook = threading.__excepthook__
55 class TestThread(threading.Thread):
57 threading.Thread.__init__(self, name=name)
103 thread = threading.Thread(name="myname1")
107 thread = threading.Thread(name=123)
111 thread = threading.Thread(target=func, name="myname2")
114 with mock.patch.object(threading, '_counter', return_value=2):
115 thread = threading.Thread(name="")
[all …]
Dtest_threading_local.py11 import threading
35 t = threading.Thread(target=target, args=(local, weaklist))
69 with threading_helper.start_threads(threading.Thread(target=f, args=(i,))
79 e1 = threading.Event()
80 e2 = threading.Event()
99 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)
Dtest_threadedtempfile.py21 import threading
29 startEvent = threading.Event()
32 class TempFileGreedy(threading.Thread):
Dssl_servers.py5 import threading
120 class HTTPSServerThread(threading.Thread):
128 threading.Thread.__init__(self)
136 threading.Thread.start(self)
157 flag = threading.Event()
Dtest_fork1.py8 import threading
22 import_started = threading.Event()
33 t = threading.Thread(target=importer)
Dtest_asynchat.py10 import threading
25 class echo_server(threading.Thread):
31 threading.Thread.__init__(self)
98 event = threading.Event()
117 event = threading.Event()
221 s.start_resend_event = threading.Event()
/third_party/gstreamer/gstplugins_bad/ext/wpe/
DWPEThreadedView.cpp74 g_mutex_init(&threading.mutex); in WPEContextThread()
75 g_cond_init(&threading.cond); in WPEContextThread()
78 GMutexHolder lock(threading.mutex); in WPEContextThread()
79 threading.thread = g_thread_new("WPEContextThread", s_viewThread, this); in WPEContextThread()
80 while (!threading.ready) { in WPEContextThread()
81 g_cond_wait(&threading.cond, &threading.mutex); in WPEContextThread()
89 if (threading.thread) { in ~WPEContextThread()
90 g_thread_unref(threading.thread); in ~WPEContextThread()
91 threading.thread = nullptr; in ~WPEContextThread()
94 g_mutex_clear(&threading.mutex); in ~WPEContextThread()
[all …]
/third_party/python/Lib/multiprocessing/dummy/
D__init__.py20 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
/third_party/ffmpeg/doc/
Dmultithreading.txt6 Slice threading decodes multiple parts of a frame at the same time, using
9 Frame threading decodes multiple frames at the same time.
17 Slice threading -
21 Frame threading -
22 * Restrictions with slice threading also apply.
31 Slice threading -
34 Frame threading -
44 Porting codecs to frame threading
/third_party/python/Lib/test/test_zoneinfo/
D_support.py4 import threading
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/
Dthreading_helper.py5 import threading
24 return _thread._count(), threading._dangling.copy()
31 values = _thread._count(), threading._dangling
200 self._old_hook = threading.excepthook
201 threading.excepthook = self._hook
205 threading.excepthook = self._old_hook
/third_party/python/Lib/test/test_importlib/
Dtest_threaded_import.py14 import threading
37 done_tasks.append(threading.get_ident())
75 self.lock = threading.Lock()
114 done = threading.Event()
129 threading.Thread(target=task, args=(N, done, done_tasks, errors,))
218 t1 = threading.Thread(target=import_ab)
219 t2 = threading.Thread(target=import_ba)
Dthreaded_import_hangers.py10 import threading
21 class Worker(threading.Thread):
23 threading.Thread.__init__(self)
/third_party/python/Lib/concurrent/futures/
Dthread.py11 import threading
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/
Dqueue.py3 import threading
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)
270 self._count = threading.Semaphore(0)
/third_party/python/Tools/ccbench/
Dccbench.py14 import threading
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.Thread(target=run))
/third_party/python/Lib/multiprocessing/
Dmanagers.py18 import threading
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
799 if threading.current_thread().name != 'MainThread':
[all …]
Dpool.py20 import threading
223 self._worker_handler = threading.Thread(
235 self._task_handler = threading.Thread(
244 self._result_handler = threading.Thread(
508 thread = threading.current_thread()
526 thread = threading.current_thread()
572 thread = threading.current_thread()
705 if threading.current_thread() is not worker_handler:
716 if threading.current_thread() is not task_handler:
720 if threading.current_thread() is not result_handler:
[all …]
Dsynchronize.py14 import threading
168 if threading.current_thread().name != 'MainThread':
169 name += '|' + threading.current_thread().name
193 if threading.current_thread().name != 'MainThread':
194 name += '|' + threading.current_thread().name
360 class Barrier(threading.Barrier):
/third_party/python/Lib/idlelib/
Drpc.py41 import threading
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/python/Lib/ctypes/test/
Dtest_errno.py2 import threading
38 t = threading.Thread(target=_worker)
67 t = threading.Thread(target=_worker)
/third_party/mesa3d/.gitlab-ci/bare-metal/
Dserial_buffer.py28 import threading
58 self.read_thread = threading.Thread(
61 self.read_thread = threading.Thread(
65 self.lines_thread = threading.Thread(
/third_party/python/Lib/asyncio/
Devents.py19 import threading
638 class _Local(threading.local):
652 threading.current_thread() is threading.main_thread()):
657 % threading.current_thread().name)
683 _lock = threading.Lock()
687 class _RunningLoop(threading.local):
/third_party/wpa_supplicant/wpa_supplicant-2.9/wpa_supplicant/examples/p2p/
Dp2p_flush.py11 import threading
30 class P2P_Flush (threading.Thread):
56 threading.Thread.__init__(self)
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/wpa_supplicant/examples/p2p/
Dp2p_flush.py11 import threading
30 class P2P_Flush (threading.Thread):
56 threading.Thread.__init__(self)

12345678910>>...17