Searched refs:threading (Results 1 – 25 of 411) sorted by relevance
12345678910>>...17
/third_party/python/Lib/test/ |
D | test_threading.py | 14 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 …]
|
D | test_threading_local.py | 11 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)
|
D | test_threadedtempfile.py | 21 import threading 29 startEvent = threading.Event() 32 class TempFileGreedy(threading.Thread):
|
D | ssl_servers.py | 5 import threading 120 class HTTPSServerThread(threading.Thread): 128 threading.Thread.__init__(self) 136 threading.Thread.start(self) 157 flag = threading.Event()
|
D | test_fork1.py | 8 import threading 22 import_started = threading.Event() 33 t = threading.Thread(target=importer)
|
D | test_asynchat.py | 10 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/ |
D | WPEThreadedView.cpp | 74 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__.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
|
/third_party/ffmpeg/doc/ |
D | multithreading.txt | 6 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.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()
|
/third_party/python/Lib/test/support/ |
D | threading_helper.py | 5 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/ |
D | test_threaded_import.py | 14 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)
|
D | threaded_import_hangers.py | 10 import threading 21 class Worker(threading.Thread): 23 threading.Thread.__init__(self)
|
/third_party/python/Lib/concurrent/futures/ |
D | thread.py | 11 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/ |
D | queue.py | 3 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/ |
D | ccbench.py | 14 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/ |
D | managers.py | 18 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 …]
|
D | pool.py | 20 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 …]
|
D | synchronize.py | 14 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/ |
D | rpc.py | 41 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/ |
D | test_errno.py | 2 import threading 38 t = threading.Thread(target=_worker) 67 t = threading.Thread(target=_worker)
|
/third_party/mesa3d/.gitlab-ci/bare-metal/ |
D | serial_buffer.py | 28 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/ |
D | events.py | 19 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/ |
D | p2p_flush.py | 11 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/ |
D | p2p_flush.py | 11 import threading 30 class P2P_Flush (threading.Thread): 56 threading.Thread.__init__(self)
|
12345678910>>...17