| /tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
| sl4a_manager.py | 16 import threading
109 self._listen_for_port_lock = threading.Lock()
|
| /tools/test/connectivity/acts/framework/acts/test_utils/bt/ |
| BluetoothBaseTest.py | 20 import threading
101 thread = threading.Thread(
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_telnetlib.py | 8 threading = test_support.import_module('threading')
variable
48 self.evt = threading.Event()
52 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
100 self.evt = threading.Event()
105 self.thread = threading.Thread(target=server, args=(self.evt,self.sock, self.dataq))
|
| test_xmlrpc.py | 17 import threading
19 threading = None
variable
417 @unittest.skipUnless(threading, 'Threading required for this test.')
427 self.evt = threading.Event()
430 threading.Thread(target=self.threadFunc, args=serv_args).start()
742 if threading:
745 # Without threading, http_server() and http_multi_server() will not
769 @unittest.skipUnless(threading, 'Threading required for this test.')
[all...] |
| /external/python/futures/concurrent/futures/ |
| _base.py | 6 import threading
61 self.event = threading.Event()
78 self.lock = threading.Lock()
116 self.lock = threading.Lock()
320 self._condition = threading.Condition()
|
| /external/python/cpython2/Lib/test/ |
| test_asyncore.py | 17 import threading
19 threading = None variable
352 @unittest.skipUnless(threading, 'Threading required for this test.')
355 evt = threading.Event()
362 t = threading.Thread(target=capture_server, args=args)
707 @unittest.skipUnless(threading, 'Threading required for this test.')
712 t = threading.Thread(target=lambda: asyncore.loop(timeout=0.1, count=500))
|
| test_xmlrpc.py | 17 import threading
19 threading = None variable
454 @unittest.skipUnless(threading, 'Threading required for this test.')
464 self.evt = threading.Event()
467 threading.Thread(target=self.threadFunc, args=serv_args).start()
[all...] |
| /external/python/cpython3/Lib/test/ |
| test_asyncore.py | 18 import threading
20 threading = None variable
329 @unittest.skipUnless(threading, 'Threading required for this test.')
332 evt = threading.Event()
339 t = threading.Thread(target=capture_server, args=args)
777 @unittest.skipUnless(threading, 'Threading required for this test.')
783 t = threading.Thread(target=lambda: asyncore.loop(timeout=0.1,
|
| test_urllib2_localnet.py | 12 threading = support.import_module('threading') variable
54 class LoopbackHttpServerThread(threading.Thread):
58 threading.Thread.__init__(self)
60 self.ready = threading.Event()
279 @unittest.skipUnless(threading, "Threading required for this test.")
316 @unittest.skipUnless(threading, "Threading required for this test.")
437 @unittest.skipUnless(threading, "Threading required for this test."
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_asyncore.py | 17 import threading
19 threading = None variable
353 @unittest.skipUnless(threading, 'Threading required for this test.')
356 evt = threading.Event()
363 t = threading.Thread(target=capture_server, args=args)
708 @unittest.skipUnless(threading, 'Threading required for this test.')
713 t = threading.Thread(target=lambda: asyncore.loop(timeout=0.1, count=500))
|
| test_xmlrpc.py | 17 import threading
19 threading = None variable
417 @unittest.skipUnless(threading, 'Threading required for this test.')
427 self.evt = threading.Event()
430 threading.Thread(target=self.threadFunc, args=serv_args).start()
751 if threading:
754 # Without threading, http_server() and http_multi_server() will not
778 @unittest.skipUnless(threading, 'Threading required for this test.'
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_asyncore.py | 17 import threading
19 threading = None variable
353 @unittest.skipUnless(threading, 'Threading required for this test.')
356 evt = threading.Event()
363 t = threading.Thread(target=capture_server, args=args)
708 @unittest.skipUnless(threading, 'Threading required for this test.')
713 t = threading.Thread(target=lambda: asyncore.loop(timeout=0.1, count=500))
|
| test_xmlrpc.py | 17 import threading
19 threading = None variable
417 @unittest.skipUnless(threading, 'Threading required for this test.')
427 self.evt = threading.Event()
430 threading.Thread(target=self.threadFunc, args=serv_args).start()
751 if threading:
754 # Without threading, http_server() and http_multi_server() will not
778 @unittest.skipUnless(threading, 'Threading required for this test.'
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_asyncore.py | 17 import threading
19 threading = None variable
353 @unittest.skipUnless(threading, 'Threading required for this test.')
356 evt = threading.Event()
363 t = threading.Thread(target=capture_server, args=args)
708 @unittest.skipUnless(threading, 'Threading required for this test.')
713 t = threading.Thread(target=lambda: asyncore.loop(timeout=0.1, count=500))
|
| test_xmlrpc.py | 17 import threading
19 threading = None variable
417 @unittest.skipUnless(threading, 'Threading required for this test.')
427 self.evt = threading.Event()
430 threading.Thread(target=self.threadFunc, args=serv_args).start()
751 if threading:
754 # Without threading, http_server() and http_multi_server() will not
778 @unittest.skipUnless(threading, 'Threading required for this test.'
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_asyncore.py | 17 import threading
19 threading = None variable
353 @unittest.skipUnless(threading, 'Threading required for this test.')
356 evt = threading.Event()
363 t = threading.Thread(target=capture_server, args=args)
708 @unittest.skipUnless(threading, 'Threading required for this test.')
713 t = threading.Thread(target=lambda: asyncore.loop(timeout=0.1, count=500))
|
| test_xmlrpc.py | 17 import threading
19 threading = None variable
417 @unittest.skipUnless(threading, 'Threading required for this test.')
427 self.evt = threading.Event()
430 threading.Thread(target=self.threadFunc, args=serv_args).start()
751 if threading:
754 # Without threading, http_server() and http_multi_server() will not
778 @unittest.skipUnless(threading, 'Threading required for this test.'
[all...] |
| /external/scapy/scapy/ |
| automaton.py | 15 import threading
89 self.trigger = threading.Lock()
100 _t = threading.Thread(target=self._wait_non_ressources, args=(callback,))
147 self.available_lock = threading.Lock()
171 threading.Thread(target=self._timeout_thread, args=(self.remain,)).start()
633 self.started = threading.Lock()
703 ready = threading.Event()
704 _t = threading.Thread(target=self._do_control, args=(ready,) + (args), kwargs=kargs)
711 self.threadid = threading.currentThread().ident
[all...] |
| /external/autotest/site_utils/chromeos_proxy/ |
| swarming_bots.py | 48 import threading
293 t = threading.Thread(target=bot.kill)
299 while threading.active_count() > 1:
|
| /external/python/cpython2/Lib/idlelib/ |
| run.py | 7 import threading
97 sockthread = threading.Thread(target=manage_socket,
179 exclude = ("run.py", "rpc.py", "threading.py", "Queue.py",
264 print>>erf, 'Thread: %s' % threading.currentThread().getName()
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| process.py | 56 import threading
403 self._shutdown_lock = threading.Lock()
416 self._queue_management_thread = threading.Thread(
|
| /external/python/cpython3/Lib/multiprocessing/ |
| util.py | 15 import threading # we want threading to install it's
328 self._lock = threading.Lock()
339 class ForkAwareLocal(threading.local):
|
| /external/tensorflow/tensorflow/python/data/kernel_tests/ |
| dataset_from_generator_op_test.py | 20 import threading
144 lock = threading.Lock()
145 condition = threading.Condition(lock)
|
| /external/toolchain-utils/crb/ |
| autotest_run.py | 7 import threading
29 class AutotestRun(threading.Thread):
52 threading.Thread.__init__(self)
|
| /external/toolchain-utils/crosperf/ |
| benchmark_run.py | 8 import threading
29 class BenchmarkRun(threading.Thread):
34 threading.Thread.__init__(self)
|
