| /external/python/cpython2/Lib/test/ |
| test_socketserver.py | 20 import threading
22 threading = None variable
72 @unittest.skipUnless(threading, 'Threading required for this test.')
145 t = threading.Thread(
306 t = threading.Thread(
|
| test_telnetlib.py | 9 threading = test_support.import_module('threading') variable
46 self.evt = threading.Event()
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
104 self.evt = threading.Event()
109 self.thread = threading.Thread(target=server, args=(self.evt,self.sock, self.dataq))
393 self.evt = threading.Event()
398 self.thread = threading.Thread(target=server, args=(self.evt,self.sock,
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| _base.py | 8 import threading
59 self.event = threading.Event()
76 self.lock = threading.Lock()
114 self.lock = threading.Lock()
287 self._condition = threading.Condition()
|
| /external/tensorflow/tensorflow/python/eager/ |
| context.py | 25 import threading
58 class _EagerContext(threading.local):
77 class ContextStack(threading.local):
138 self._initialize_lock = threading.Lock()
461 _context_lock = threading.Lock()
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_hashlib.py | 14 import threading
16 threading = None variable
358 @unittest.skipUnless(threading, 'Threading required for this test.')
385 event = threading.Event()
387 threading.Thread(target=hash_in_chunks,
|
| test_ssl.py | 401 import threading
407 class ThreadedEchoServer(threading.Thread):
409 class ConnectionHandler(threading.Thread):
421 threading.Thread.__init__(self)
558 threading.Thread.__init__(self)
562 self.start(threading.Event())
572 threading.Thread.start(self)
599 class AsyncoreEchoServer(threading.Thread):
671 threading.Thread.__init__(self)
678 self.start(threading.Event()
[all...] |
| test_telnetlib.py | 9 threading = test_support.import_module('threading') variable
46 self.evt = threading.Event()
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
96 self.evt = threading.Event()
101 self.thread = threading.Thread(target=server, args=(self.evt,self.sock, self.dataq))
386 self.evt = threading.Event()
391 self.thread = threading.Thread(target=server, args=(self.evt,self.sock,
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_hashlib.py | 14 import threading
16 threading = None variable
358 @unittest.skipUnless(threading, 'Threading required for this test.')
385 event = threading.Event()
387 threading.Thread(target=hash_in_chunks,
|
| test_ssl.py | 401 import threading
407 class ThreadedEchoServer(threading.Thread):
409 class ConnectionHandler(threading.Thread):
421 threading.Thread.__init__(self)
558 threading.Thread.__init__(self)
562 self.start(threading.Event())
572 threading.Thread.start(self)
599 class AsyncoreEchoServer(threading.Thread):
671 threading.Thread.__init__(self)
678 self.start(threading.Event()
[all...] |
| test_telnetlib.py | 9 threading = test_support.import_module('threading') variable
46 self.evt = threading.Event()
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
96 self.evt = threading.Event()
101 self.thread = threading.Thread(target=server, args=(self.evt,self.sock, self.dataq))
386 self.evt = threading.Event()
391 self.thread = threading.Thread(target=server, args=(self.evt,self.sock,
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_hashlib.py | 14 import threading
16 threading = None variable
358 @unittest.skipUnless(threading, 'Threading required for this test.')
385 event = threading.Event()
387 threading.Thread(target=hash_in_chunks,
|
| test_ssl.py | 401 import threading
407 class ThreadedEchoServer(threading.Thread):
409 class ConnectionHandler(threading.Thread):
421 threading.Thread.__init__(self)
558 threading.Thread.__init__(self)
562 self.start(threading.Event())
572 threading.Thread.start(self)
599 class AsyncoreEchoServer(threading.Thread):
671 threading.Thread.__init__(self)
678 self.start(threading.Event()
[all...] |
| test_telnetlib.py | 9 threading = test_support.import_module('threading') variable
46 self.evt = threading.Event()
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
96 self.evt = threading.Event()
101 self.thread = threading.Thread(target=server, args=(self.evt,self.sock, self.dataq))
386 self.evt = threading.Event()
391 self.thread = threading.Thread(target=server, args=(self.evt,self.sock,
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_hashlib.py | 14 import threading
16 threading = None variable
358 @unittest.skipUnless(threading, 'Threading required for this test.')
385 event = threading.Event()
387 threading.Thread(target=hash_in_chunks,
|
| test_ssl.py | 401 import threading
407 class ThreadedEchoServer(threading.Thread):
409 class ConnectionHandler(threading.Thread):
421 threading.Thread.__init__(self)
558 threading.Thread.__init__(self)
562 self.start(threading.Event())
572 threading.Thread.start(self)
599 class AsyncoreEchoServer(threading.Thread):
671 threading.Thread.__init__(self)
678 self.start(threading.Event()
[all...] |
| test_telnetlib.py | 9 threading = test_support.import_module('threading') variable
46 self.evt = threading.Event()
50 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
96 self.evt = threading.Event()
101 self.thread = threading.Thread(target=server, args=(self.evt,self.sock, self.dataq))
386 self.evt = threading.Event()
391 self.thread = threading.Thread(target=server, args=(self.evt,self.sock,
|
| /art/test/testrunner/ |
| testrunner.py | 58 import threading
91 test_count_mutex = threading.Lock()
99 semaphore = threading.Semaphore(1)
103 print_mutex = threading.Lock()
255 semaphore = threading.Semaphore(n_thread)
383 while threading.active_count() > 2:
514 worker = threading.Thread(target=run_test, args=(command, test, variant_set, test_name))
526 while threading.active_count() > 2:
[all...] |
| /external/python/cpython2/Lib/sqlite3/test/ |
| dbapi.py | 29 import threading
31 threading = None variable
479 @unittest.skipUnless(threading, 'This test requires threading.')
502 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
520 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
538 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
556 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
574 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors})
592 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors}
[all...] |
| /external/python/cpython3/Lib/test/ |
| lock_tests.py | 8 import threading
35 tid = threading.get_ident()
159 # (non-threading) thread.
164 n = len(threading.enumerate())
168 if len(threading.enumerate()) != n:
174 self.assertEqual(n, len(threading.enumerate()))
432 lock = threading.Lock()
821 except threading.BrokenBarrierError:
850 except threading.BrokenBarrierError:
877 except threading.BrokenBarrierError
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/sqlite3/test/ |
| dbapi.py | 28 import threading
30 threading = None variable
478 @unittest.skipUnless(threading, 'This test requires threading.')
501 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
519 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
537 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
555 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
573 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors})
591 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors}
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/sqlite3/test/ |
| dbapi.py | 28 import threading
30 threading = None variable
478 @unittest.skipUnless(threading, 'This test requires threading.')
501 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
519 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
537 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
555 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
573 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors})
591 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors}
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/sqlite3/test/ |
| dbapi.py | 28 import threading
30 threading = None variable
478 @unittest.skipUnless(threading, 'This test requires threading.')
501 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
519 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
537 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
555 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
573 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors})
591 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors}
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/sqlite3/test/ |
| dbapi.py | 28 import threading
30 threading = None variable
478 @unittest.skipUnless(threading, 'This test requires threading.')
501 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
519 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
537 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
555 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
573 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors})
591 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors}
[all...] |
| /external/python/cpython3/Lib/asyncio/ |
| events.py | 19 import threading
566 class _Local(threading.local):
580 isinstance(threading.current_thread(), threading._MainThread)):
584 % threading.current_thread().name)
609 _lock = threading.Lock()
613 class _RunningLoop(threading.local):
|
| /external/tensorflow/tensorflow/python/keras/_impl/keras/utils/ |
| data_utils.py | 31 import threading
489 use_multiprocessing: use multiprocessing if True, otherwise threading
540 self.stop_signal = threading.Event()
541 self.run_thread = threading.Thread(target=self._run)
631 use_multiprocessing: use multiprocessing if True, otherwise threading
724 self.genlock = threading.Lock()
726 self._stop_event = threading.Event()
738 thread = threading.Thread(target=self._data_generator_task)
|
