/external/autotest/frontend/ |
H A D | thread_local.py | 1 import threading namespace 3 _store = threading.local()
|
/external/python/cpython2/Lib/test/ |
H A D | threaded_import_hangers.py | 10 import threading namespace 21 class Worker(threading.Thread): 23 threading.Thread.__init__(self)
|
H A D | test_nntplib.py | 7 import threading namespace 9 threading = None variable 37 self.evt = threading.Event() 41 threading.Thread( 50 @unittest.skipUnless(threading, 'threading required') 59 @unittest.skipUnless(threading, 'threading required')
|
H A D | test_threading.py | 1 # Very rudimentary test of threading module 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 [all...] |
H A D | test_capi.py | 12 import threading namespace 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)
|
/external/python/cpython3/Lib/test/ |
H A D | threaded_import_hangers.py | 10 import threading namespace 21 class Worker(threading.Thread): 23 threading.Thread.__init__(self)
|
H A D | test_threading.py | 2 Tests for the threading module. 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 [all...] |
/external/chromium-trace/catapult/devil/devil/utils/lazy/ |
H A D | weak_constant.py | 5 import threading namespace 18 self._lock = threading.Lock()
|
/external/libmojo/third_party/catapult/devil/devil/utils/lazy/ |
H A D | weak_constant.py | 5 import threading namespace 18 self._lock = threading.Lock()
|
/external/tensorflow/tensorflow/python/training/ |
H A D | coordinator_test.py | 22 import threading namespace 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 [all...] |
/external/python/cpython2/Lib/multiprocessing/dummy/ |
H A D | __init__.py | 45 import threading namespace 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/python/cpython3/Tools/scripts/ |
H A D | run_tests.py | 14 import threading namespace 16 threading = None variable 45 if threading and not any(is_multiprocess_flag(arg) for arg in regrtest_args):
|
/external/mesa3d/scons/ |
H A D | fixes.py | 6 import threading namespace 9 spawn_lock = threading.Lock()
|
/external/autotest/server/cros/ |
H A D | stress_unittest.py | 5 import threading namespace 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()
|
H A D | lockfile.py | 55 import threading namespace 59 # Work with PEP8 and non-PEP8 versions of threading module. 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()
|
/external/python/cpython3/Lib/multiprocessing/dummy/ |
H A D | __init__.py | 20 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) 48 threading.Thread.start(self) 62 current_process = threading.current_thread
|
/external/python/cpython2/Lib/ctypes/test/ |
H A D | test_errno.py | 6 import threading namespace 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/ |
H A D | test_errno.py | 5 import threading namespace 7 threading = None variable 28 if threading: 41 t = threading.Thread(target=_worker) 70 t = threading.Thread(target=_worker)
|
/external/autotest/client/cros/ |
H A D | dark_resume_listener.py | 6 import threading namespace 41 thread = threading.Thread(None, loop_runner)
|
/external/autotest/site_utils/lxc/container_pool/ |
H A D | unittest_client.py | 7 import threading namespace 23 class _ClientFactory(threading.Thread):
|
/external/libmojo/third_party/catapult/devil/devil/android/ |
H A D | device_temp_file.py | 11 import threading namespace 48 threading.Thread(
|
/external/tensorflow/tensorflow/contrib/slim/python/slim/ |
H A D | queues.py | 26 import threading namespace 36 _queue_runner_lock = threading.Lock()
|
/external/tensorflow/tensorflow/python/summary/writer/ |
H A D | writer_cache.py | 21 import threading namespace 38 _lock = threading.RLock()
|
/external/google-benchmark/ |
H A 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, 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][exception [all...] |
/external/ltp/testcases/kernel/io/disktest/ |
H A D | Makefile.aix | 76 # reworked threading code 139 ALLHDRS=main.h sfunc.h parse.h childmain.h threading.h globals.h usage.h Getopt.h io.h dump.h timer.h stats.h signals.h 140 SRCS=main.c sfunc.c parse.c childmain.c threading.c globals.c usage.c Getopt.c io.c dump.c timer.c stats.c signals.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 stats.o signals.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)
|