| /external/testng/src/test/java/test/ant/ |
| MultipleThreadTest.java | 17 public static Set<Thread> _threads;
field in class:MultipleThreadTest
21 _threads=Collections.synchronizedSet(new HashSet<Thread>());
26 _threads.add(Thread.currentThread());
31 _threads.add(Thread.currentThread());
36 _threads.add(Thread.currentThread());
41 _threads.add(Thread.currentThread());
46 _threads.add(Thread.currentThread());
51 _threads.add(Thread.currentThread());
56 _threads.add(Thread.currentThread());
61 _threads.add(Thread.currentThread());
[all...] |
| /external/chromium-trace/catapult/devil/devil/utils/ |
| reraiser_thread.py | 95 self._threads = []
112 self._threads.append(thread)
127 for thread in self._threads:
144 alive_threads = self._threads[:]
151 (len(alive_threads), len(self._threads)))
157 for thread in self._threads:
168 return any(t.isAlive() for t in self._threads)
189 for thread in (t for t in self._threads if t.isAlive()):
199 if any([t.isAlive() for t in self._threads]):
201 return [t.GetReturnValue() for t in self._threads]
[all...] |
| /external/libmojo/third_party/catapult/devil/devil/utils/ |
| reraiser_thread.py | 95 self._threads = []
112 self._threads.append(thread)
127 for thread in self._threads:
144 alive_threads = self._threads[:]
151 (len(alive_threads), len(self._threads)))
157 for thread in self._threads:
168 return any(t.isAlive() for t in self._threads)
189 for thread in (t for t in self._threads if t.isAlive()):
199 if any([t.isAlive() for t in self._threads]):
201 return [t.GetReturnValue() for t in self._threads]
[all...] |
| /external/libxcam/modules/soft/ |
| soft_worker.cpp | 133 ERROR, !_threads.ptr (), false,
135 _threads = threads;
166 _threads->stop ();
196 if (!_threads.ptr ()) {
199 _threads = new ThreadPool (thr_name);
200 XCAM_ASSERT (_threads.ptr ());
201 _threads->set_threads (max_items, max_items + 1); //extra thread to process all_items_done
202 ret = _threads->start ();
214 ret = _threads->queue (item);
|
| soft_handler.cpp | 98 _threads = pool;
136 if (_threads.ptr () && !_threads->is_running ()) {
137 ret = _threads->start ();
|
| soft_worker.h | 93 SmartPtr<ThreadPool> _threads; member in class:XCam::SoftWorker
|
| soft_handler.h | 87 SmartPtr<ThreadPool> _threads; member in class:XCam::SoftHandler
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| thread.py | 101 self._threads = set()
126 num_threads = len(self._threads)
135 self._threads.add(t)
143 for t in self._threads:
|
| /external/python/futures/concurrent/futures/ |
| thread.py | 115 self._threads = set()
141 num_threads = len(self._threads)
150 self._threads.add(t)
158 for t in self._threads:
|
| /external/ltp/testcases/realtime/lib/ |
| librttest.c | 64 static LIST_HEAD(_threads);
297 list_add_tail(&thread->_threads, &_threads);
317 list_del(&thread->_threads);
369 list_for_each_entry(p, &_threads, _threads) {
379 list_del(&t->_threads);
386 list_for_each_entry(p, &_threads, _threads) {
395 list_for_each_entry_safe(p, t, &_threads, _threads)
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_docxmlrpc.py | 72 self._threads = test_support.threading_setup()
94 test_support.threading_cleanup(*self._threads)
|
| test_smtplib.py | 47 self._threads = test_support.threading_setup()
61 test_support.threading_cleanup(*self._threads)
155 self._threads = test_support.threading_setup()
176 test_support.threading_cleanup(*self._threads)
273 self._threads = test_support.threading_setup()
287 test_support.threading_cleanup(*self._threads)
400 self._threads = test_support.threading_setup()
421 test_support.threading_cleanup(*self._threads)
|
| test_asynchat.py | 104 self._threads = test_support.threading_setup()
107 test_support.threading_cleanup(*self._threads)
|
| /external/python/cpython2/Lib/test/ |
| test_smtplib.py | 47 self._threads = test_support.threading_setup()
61 test_support.threading_cleanup(*self._threads)
155 self._threads = test_support.threading_setup()
176 test_support.threading_cleanup(*self._threads)
273 self._threads = test_support.threading_setup()
287 test_support.threading_cleanup(*self._threads)
426 self._threads = test_support.threading_setup()
447 test_support.threading_cleanup(*self._threads)
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_docxmlrpc.py | 72 self._threads = test_support.threading_setup()
94 test_support.threading_cleanup(*self._threads)
|
| test_smtplib.py | 47 self._threads = test_support.threading_setup()
61 test_support.threading_cleanup(*self._threads)
155 self._threads = test_support.threading_setup()
176 test_support.threading_cleanup(*self._threads)
273 self._threads = test_support.threading_setup()
287 test_support.threading_cleanup(*self._threads)
399 self._threads = test_support.threading_setup()
420 test_support.threading_cleanup(*self._threads)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_docxmlrpc.py | 72 self._threads = test_support.threading_setup()
94 test_support.threading_cleanup(*self._threads)
|
| test_smtplib.py | 47 self._threads = test_support.threading_setup()
61 test_support.threading_cleanup(*self._threads)
155 self._threads = test_support.threading_setup()
176 test_support.threading_cleanup(*self._threads)
273 self._threads = test_support.threading_setup()
287 test_support.threading_cleanup(*self._threads)
399 self._threads = test_support.threading_setup()
420 test_support.threading_cleanup(*self._threads)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_docxmlrpc.py | 72 self._threads = test_support.threading_setup()
94 test_support.threading_cleanup(*self._threads)
|
| test_smtplib.py | 47 self._threads = test_support.threading_setup()
61 test_support.threading_cleanup(*self._threads)
155 self._threads = test_support.threading_setup()
176 test_support.threading_cleanup(*self._threads)
273 self._threads = test_support.threading_setup()
287 test_support.threading_cleanup(*self._threads)
399 self._threads = test_support.threading_setup()
420 test_support.threading_cleanup(*self._threads)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_docxmlrpc.py | 72 self._threads = test_support.threading_setup()
94 test_support.threading_cleanup(*self._threads)
|
| test_smtplib.py | 47 self._threads = test_support.threading_setup()
61 test_support.threading_cleanup(*self._threads)
155 self._threads = test_support.threading_setup()
176 test_support.threading_cleanup(*self._threads)
273 self._threads = test_support.threading_setup()
287 test_support.threading_cleanup(*self._threads)
399 self._threads = test_support.threading_setup()
420 test_support.threading_cleanup(*self._threads)
|
| /art/tools/ |
| stream-trace-converter.py | 124 self._threads.append('%d\t%s\n' % (tid, str))
174 for t in self._threads:
191 self._threads = []
|
| /external/tensorflow/tensorflow/python/keras/_impl/keras/utils/ |
| data_utils.py | 654 self._threads = []
739 self._threads.append(thread)
759 for thread in self._threads:
773 self._threads = []
797 all_finished = all([not thread.is_alive() for thread in self._threads])
|
| /external/ltp/testcases/realtime/include/ |
| librttest.h | 81 struct list_head _threads; member in struct:thread
|
