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

1234567891011>>

/external/autotest/frontend/
H A Dthread_local.py1 import threading namespace
3 _store = threading.local()
/external/python/cpython2/Lib/test/
H A Dthreaded_import_hangers.py10 import threading namespace
21 class Worker(threading.Thread):
23 threading.Thread.__init__(self)
H A Dtest_nntplib.py7 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 Dtest_threading.py1 # 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 Dtest_capi.py12 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 Dthreaded_import_hangers.py10 import threading namespace
21 class Worker(threading.Thread):
23 threading.Thread.__init__(self)
H A Dtest_threading.py2 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 Dweak_constant.py5 import threading namespace
18 self._lock = threading.Lock()
/external/libmojo/third_party/catapult/devil/devil/utils/lazy/
H A Dweak_constant.py5 import threading namespace
18 self._lock = threading.Lock()
/external/tensorflow/tensorflow/python/training/
H A Dcoordinator_test.py22 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__.py45 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 Drun_tests.py14 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 Dfixes.py6 import threading namespace
9 spawn_lock = threading.Lock()
/external/autotest/server/cros/
H A Dstress_unittest.py5 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 Dlockfile.py55 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__.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)
48 threading.Thread.start(self)
62 current_process = threading.current_thread
/external/python/cpython2/Lib/ctypes/test/
H A Dtest_errno.py6 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 Dtest_errno.py5 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 Ddark_resume_listener.py6 import threading namespace
41 thread = threading.Thread(None, loop_runner)
/external/autotest/site_utils/lxc/container_pool/
H A Dunittest_client.py7 import threading namespace
23 class _ClientFactory(threading.Thread):
/external/libmojo/third_party/catapult/devil/devil/android/
H A Ddevice_temp_file.py11 import threading namespace
48 threading.Thread(
/external/tensorflow/tensorflow/contrib/slim/python/slim/
H A Dqueues.py26 import threading namespace
36 _queue_runner_lock = threading.Lock()
/external/tensorflow/tensorflow/python/summary/writer/
H A Dwriter_cache.py21 import threading namespace
38 _lock = threading.RLock()
/external/google-benchmark/
H A Dmingw.py80 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 DMakefile.aix76 # 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)

Completed in 1127 milliseconds

1234567891011>>