| /external/python/cpython3/Lib/multiprocessing/ |
| queues.py | 14 import threading
69 self._notempty = threading.Condition(threading.Lock())
160 self._thread = threading.Thread(
|
| /external/python/cpython3/Lib/ |
| socketserver.py | 23 - threading (each request is handled by a new thread)
52 Forking and threading versions of each type of server can be created
54 instance, a threading UDP server class is created as follows:
77 you can use a threading server, but you will probably have to use
85 to read all the data it has requested. Here a threading or forking
132 import threading
134 import dummy_threading as threading
208 self.__is_shut_down = threading.Event()
647 t = threading.Thread(target = self.process_request_thread,
|
| /external/skia/tools/skpbench/ |
| skpbench.py | 14 from threading import Thread, Timer
|
| /external/skqp/tools/skpbench/ |
| skpbench.py | 14 from threading import Thread, Timer
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| stage_op_test.py | 179 import threading
193 t = threading.Thread(target=thread_run)
242 import threading
257 t = threading.Thread(target=thread_run)
|
| /external/tensorflow/tensorflow/python/training/ |
| queue_runner_impl.py | 21 import threading
108 self._lock = threading.Lock()
336 ret_threads.append(threading.Thread(target=self._run,
341 ret_threads.append(threading.Thread(target=self._close_on_stop,
|
| /external/v8/tools/testrunner/local/ |
| commands.py | 32 from threading import Timer
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/ |
| SocketServer.py | 23 - threading (each request is handled by a new thread)
52 Forking and threading versions of each type of server can be created
54 instance, a threading UDP server class is created as follows:
77 you can use a threading server, but you will probably have to use
85 to read all the data it has requested. Here a threading or forking
138 import threading
140 import dummy_threading as threading
210 self.__is_shut_down = threading.Event()
601 t = threading.Thread(target = self.process_request_thread,
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/ |
| queues.py | 39 import threading
88 self._notempty = threading.Condition(threading.Lock())
182 self._thread = threading.Thread(
|
| /prebuilts/gdb/linux-x86/lib/python2.7/ |
| SocketServer.py | 23 - threading (each request is handled by a new thread)
52 Forking and threading versions of each type of server can be created
54 instance, a threading UDP server class is created as follows:
77 you can use a threading server, but you will probably have to use
85 to read all the data it has requested. Here a threading or forking
138 import threading
140 import dummy_threading as threading
210 self.__is_shut_down = threading.Event()
601 t = threading.Thread(target = self.process_request_thread,
|
| /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/ |
| queues.py | 39 import threading
88 self._notempty = threading.Condition(threading.Lock())
182 self._thread = threading.Thread(
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/ |
| SocketServer.py | 23 - threading (each request is handled by a new thread)
52 Forking and threading versions of each type of server can be created
54 instance, a threading UDP server class is created as follows:
77 you can use a threading server, but you will probably have to use
85 to read all the data it has requested. Here a threading or forking
138 import threading
140 import dummy_threading as threading
210 self.__is_shut_down = threading.Event()
601 t = threading.Thread(target = self.process_request_thread,
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| queues.py | 39 import threading
88 self._notempty = threading.Condition(threading.Lock())
182 self._thread = threading.Thread(
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/ |
| SocketServer.py | 23 - threading (each request is handled by a new thread)
52 Forking and threading versions of each type of server can be created
54 instance, a threading UDP server class is created as follows:
77 you can use a threading server, but you will probably have to use
85 to read all the data it has requested. Here a threading or forking
138 import threading
140 import dummy_threading as threading
210 self.__is_shut_down = threading.Event()
601 t = threading.Thread(target = self.process_request_thread,
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| queues.py | 39 import threading
88 self._notempty = threading.Condition(threading.Lock())
182 self._thread = threading.Thread(
|
| /system/tpm/tpm_manager/server/ |
| tpm_manager_service.h | 25 #include <base/threading/thread.h>
45 // THREADING NOTES:
|
| /system/tpm/trunks/ |
| background_command_transceiver.cc | 25 #include <base/threading/thread_task_runner_handle.h>
|
| trunksd.cc | 22 #include <base/threading/thread.h>
|
| /tools/test/connectivity/acts/tests/google/bt/system_tests/ |
| RfcommStressTest.py | 21 import threading
|
| /external/python/cpython3/Lib/sqlite3/test/ |
| dbapi.py | 27 import threading
29 threading = None variable
506 @unittest.skipUnless(threading, 'This test requires threading.')
529 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
547 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
565 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
583 t = threading.Thread(target=run, kwargs={"con": self.con, "errors": errors})
601 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors})
619 t = threading.Thread(target=run, kwargs={"cur": self.cur, "errors": errors}
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_ftplib.py | 21 threading = test_support.import_module('threading')
variable
207 class DummyFTPServer(asyncore.dispatcher, threading.Thread):
212 threading.Thread.__init__(self)
218 self.active_lock = threading.Lock()
223 self.__flag = threading.Event()
224 threading.Thread.start(self)
668 self.evt = threading.Event()
672 threading.Thread(target=self.server, args=(self.evt,self.sock)).start()
|
| test_imaplib.py | 3 # threading, this test module should be split. Right now we skip
4 # them all if we don't have threading.
5 threading = support.import_module('threading')
variable
123 t = threading.Thread(
|
| /external/autotest/client/common_lib/ |
| barrier_unittest.py | 5 import os, sys, socket, errno, unittest, threading
183 client = threading.Thread(target=_thread_rdv,
|
| /external/autotest/client/cros/ |
| memory_bandwidth_logger.py | 12 import threading
140 class MemoryBandwidthLogger(threading.Thread):
|
| /external/autotest/client/site_tests/platform_MetricsUploader/ |
| platform_MetricsUploader.py | 10 import threading
66 self.server_thread = threading.Thread(target=self.serve_forever)
|
