| /external/autotest/client/cros/ |
| dhcp_test_server.py | 53 import threading
63 class DhcpTestServer(threading.Thread):
71 self._mutex = threading.Lock()
|
| httpd.py | 13 import threading, urllib, urlparse
179 self._server_thread = threading.Thread(
184 e = threading.Event()
|
| /external/autotest/site_utils/lxc/container_pool/ |
| service.py | 7 import threading
125 self._stop_event = threading.Event()
169 class _ClientThread(threading.Thread):
|
| pool_unittest.py | 9 import threading
89 except threading.ThreadError:
489 self.create_cv = threading.Condition()
491 self.lock_destroy_count = threading.Lock()
|
| /external/devlib/devlib/utils/ |
| rendering.py | 8 import threading
24 class FrameCollector(threading.Thread):
30 self.stop_signal = threading.Event()
|
| /external/python/cpython2/Lib/multiprocessing/ |
| util.py | 39 import threading # we want threading to install it's
342 self._lock = threading.Lock()
346 class ForkAwareLocal(threading.local):
|
| queues.py | 39 import threading
88 self._notempty = threading.Condition(threading.Lock())
186 self._thread = threading.Thread(
|
| /external/python/futures/concurrent/futures/ |
| process.py | 50 import threading
297 self._shutdown_lock = threading.Lock()
307 self._queue_management_thread = threading.Thread(
|
| /external/tensorflow/tensorflow/contrib/cloud/python/ops/ |
| bigquery_reader_ops_test.py | 25 import threading
101 class FakeBigQueryServer(threading.Thread):
111 threading.Thread.__init__(self)
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/idlelib/ |
| run.py | 8 import threading
82 sockthread = threading.Thread(target=manage_socket,
163 exclude = ("run.py", "rpc.py", "threading.py", "Queue.py",
245 print>>erf, 'Thread: %s' % threading.currentThread().getName()
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/ |
| util.py | 38 import threading # we want threading to install it's
336 self._lock = threading.Lock()
340 class ForkAwareLocal(threading.local):
|
| /prebuilts/gdb/linux-x86/lib/python2.7/idlelib/ |
| run.py | 8 import threading
82 sockthread = threading.Thread(target=manage_socket,
163 exclude = ("run.py", "rpc.py", "threading.py", "Queue.py",
245 print>>erf, 'Thread: %s' % threading.currentThread().getName()
|
| /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/ |
| util.py | 38 import threading # we want threading to install it's
336 self._lock = threading.Lock()
340 class ForkAwareLocal(threading.local):
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/idlelib/ |
| run.py | 8 import threading
82 sockthread = threading.Thread(target=manage_socket,
163 exclude = ("run.py", "rpc.py", "threading.py", "Queue.py",
245 print>>erf, 'Thread: %s' % threading.currentThread().getName()
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| util.py | 38 import threading # we want threading to install it's
336 self._lock = threading.Lock()
340 class ForkAwareLocal(threading.local):
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/idlelib/ |
| run.py | 8 import threading
82 sockthread = threading.Thread(target=manage_socket,
163 exclude = ("run.py", "rpc.py", "threading.py", "Queue.py",
245 print>>erf, 'Thread: %s' % threading.currentThread().getName()
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| util.py | 38 import threading # we want threading to install it's
336 self._lock = threading.Lock()
340 class ForkAwareLocal(threading.local):
|
| /test/framework/harnesses/host_controller/vti_interface/ |
| vti_endpoint_client.py | 19 import threading
279 thread = threading.currentThread()
296 self._heartbeat_thread = threading.Thread(
|
| /tools/test/connectivity/acts/framework/acts/controllers/ |
| arduino_wifi_dongle.py | 22 import threading
135 self.lock = threading.Lock()
245 t = threading.Thread(target=self._start_log)
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.10/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
138 import threading
140 import dummy_threading as threading
210 self.__is_shut_down = threading.Event()
607 t = threading.Thread(target = self.process_request_thread,
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/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 reqd all the data it has requested. Here a threading or forking
137 import threading
139 import dummy_threading as threading
200 self.__is_shut_down = threading.Event()
590 t = threading.Thread(target = self.process_request_thread,
|
| /external/autotest/client/site_tests/video_JDAPerf/ |
| video_JDAPerf.py | 6 import threading
170 thread = threading.Thread(target=self.start_decode,
177 thread = threading.Thread(target=self.start_decode,
|
| /external/autotest/server/site_tests/firmware_BaseECKeyboard/ |
| firmware_BaseECKeyboard.py | 7 from threading import Timer
|
| /external/python/cpython2/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
133 import threading
135 import dummy_threading as threading
205 self.__is_shut_down = threading.Event()
604 t = threading.Thread(target = self.process_request_thread,
|
| /external/python/cpython3/Lib/ |
| _threading_local.py | 3 (Note that this module provides a Python version of the threading.local
6 `threading`.)
36 >>> import threading
37 >>> thread = threading.Thread(target=f)
96 >>> thread = threading.Thread(target=f)
123 >>> thread = threading.Thread(target=f)
140 # We need to use objects from the threading module, but the threading
143 # with circular imports. For that reason, we don't import `threading`
246 from threading import current_thread, RLoc
[all...] |
