| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/idlelib/ |
| run.py | 8 import threading namespace
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 namespace
336 self._lock = threading.Lock()
340 class ForkAwareLocal(threading.local):
|
| queues.py | 39 import threading namespace
88 self._notempty = threading.Condition(threading.Lock())
182 self._thread = threading.Thread(
|
| heap.py | 40 import threading namespace
96 self._lock = threading.Lock()
|
| /external/chromium_org/chrome/common/extensions/docs/examples/api/nativeMessaging/host/ |
| native-messaging-example-host | 11 import threading namespace
111 thread = threading.Thread(target=read_thread_func, args=(queue,))
|
| /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 namespace
140 import dummy_threading as threading namespace
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 namespace
88 self._notempty = threading.Condition(threading.Lock())
182 self._thread = threading.Thread(
|
| heap.py | 40 import threading namespace
96 self._lock = threading.Lock()
|
| /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 namespace
140 import dummy_threading as threading namespace
210 self.__is_shut_down = threading.Event()
601 t = threading.Thread(target = self.process_request_thread,
|
| /external/chromium_org/third_party/google_appengine_cloudstorage/cloudstorage/ |
| api_utils.py | 28 import threading namespace
52 _thread_local_settings = threading.local()
|
| /external/chromium_org/tools/telemetry/third_party/pyserial/serial/urlhandler/ |
| protocol_loop.py | 19 import threading namespace
44 self.buffer_lock = threading.Lock()
|
| /external/chromium_org/v8/tools/testrunner/server/ |
| work_handler.py | 33 import threading namespace
149 self.job_lock = threading.Lock()
|
| /external/sonivox/jet_tools/JetCreator/ |
| JetPreview.py | 26 import threading
namespace
42 self.playerLock = threading.RLock()
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/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(
|
| test_asyncore.py | 17 import threading namespace
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 namespace
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_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(
|
| test_asyncore.py | 17 import threading namespace
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 namespace
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/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
| mux.py | 45 import threading namespace
550 self._write_condition = threading.Condition()
553 self._read_condition = threading.Condition()
831 self._send_condition = threading.Condition()
839 self._write_inner_frame_semaphore = threading.Semaphore()
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| mock.py | 36 import threading namespace
|
| /external/chromium_org/third_party/jinja2/ |
| _compat.py | 148 from threading import Lock as allocate_lock
|
| /external/chromium_org/third_party/mesa/src/src/glx/ |
| glxcurrent.c | 149 #error Unknown threading method specified.
|
