| /external/testng/src/test/java/test/ant/ |
| D | MultipleThreadTest.java | 17 public static Set<Thread> _threads; field in MultipleThreadTest
21 _threads=Collections.synchronizedSet(new HashSet<Thread>()); in prepareHashSet()
26 _threads.add(Thread.currentThread()); in recordThread00()
31 _threads.add(Thread.currentThread()); in recordThread01()
36 _threads.add(Thread.currentThread()); in recordThread02()
41 _threads.add(Thread.currentThread()); in recordThread03()
46 _threads.add(Thread.currentThread()); in recordThread04()
51 _threads.add(Thread.currentThread()); in recordThread05()
56 _threads.add(Thread.currentThread()); in recordThread06()
61 _threads.add(Thread.currentThread()); in recordThread07()
[all …]
|
| /external/chromium-trace/catapult/devil/devil/utils/ |
| D | reraiser_thread.py | 98 self._threads = []
115 self._threads.append(thread)
130 for thread in self._threads:
147 alive_threads = self._threads[:]
154 (len(alive_threads), len(self._threads)))
160 for thread in self._threads:
171 return any(t.isAlive() for t in self._threads)
192 for thread in (t for t in self._threads if t.isAlive()):
202 if any([t.isAlive() for t in self._threads]):
204 return [t.GetReturnValue() for t in self._threads]
|
| /external/ltp/testcases/realtime/lib/ |
| D | librttest.c | 64 static LIST_HEAD(_threads);
297 list_add_tail(&thread->_threads, &_threads); in create_thread()
317 list_del(&thread->_threads); in create_thread()
369 list_for_each_entry(p, &_threads, _threads) { in join_thread()
379 list_del(&t->_threads); in join_thread()
386 list_for_each_entry(p, &_threads, _threads) { in all_threads_quit()
395 list_for_each_entry_safe(p, t, &_threads, _threads) { in join_threads()
398 list_del(&p->_threads); in join_threads()
405 list_for_each_entry(p, &_threads, _threads) { in get_thread()
|
| /external/libxcam/modules/soft/ |
| D | soft_worker.cpp | 133 ERROR, !_threads.ptr (), false, in set_threads()
135 _threads = threads; in set_threads()
166 _threads->stop (); in stop()
196 if (!_threads.ptr ()) { in work()
199 _threads = new ThreadPool (thr_name); in work()
200 XCAM_ASSERT (_threads.ptr ()); in work()
201 _threads->set_threads (max_items, max_items + 1); //extra thread to process all_items_done in work()
202 ret = _threads->start (); in work()
214 ret = _threads->queue (item); in work()
|
| D | soft_handler.cpp | 98 _threads = pool; in set_threads()
136 if (_threads.ptr () && !_threads->is_running ()) { in confirm_configured()
137 ret = _threads->start (); in confirm_configured()
|
| D | soft_worker.h | 93 SmartPtr<ThreadPool> _threads;
|
| D | soft_handler.h | 87 SmartPtr<ThreadPool> _threads;
|
| /external/python/futures/concurrent/futures/ |
| D | thread.py | 115 self._threads = set()
141 num_threads = len(self._threads)
150 self._threads.add(t)
158 for t in self._threads:
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | thread.py | 136 self._threads = set()
171 num_threads = len(self._threads)
182 self._threads.add(t)
203 for t in self._threads:
|
| /external/python/cpython3/Lib/ |
| D | socketserver.py | 641 _threads = None variable in ThreadingMixIn
662 if self._threads is None:
663 self._threads = []
664 self._threads.append(t)
670 threads = self._threads
671 self._threads = None
|
| /external/python/cpython2/Lib/test/ |
| D | 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)
428 self._threads = test_support.threading_setup()
449 test_support.threading_cleanup(*self._threads)
|
| D | test_asynchat.py | 108 self._threads = test_support.threading_setup()
111 test_support.threading_cleanup(*self._threads)
|
| D | lock_tests.py | 63 self._threads = support.threading_setup()
66 support.threading_cleanup(*self._threads)
|
| D | test_threading.py | 69 self._threads = test.test_support.threading_setup()
72 test.test_support.threading_cleanup(*self._threads)
|
| D | test_urllib2_localnet.py | 278 self._threads = test_support.threading_setup()
282 test_support.threading_cleanup(*self._threads)
|
| D | test_file2k.py | 490 self._threads = test_support.threading_setup()
510 test_support.threading_cleanup(*self._threads)
|
| D | test_httpservers.py | 74 self._threads = test_support.threading_setup()
84 test_support.threading_cleanup(*self._threads)
|
| /external/python/futures/ |
| D | test_futures.py | 209 self.assertEqual(len(self.executor._threads), 3)
211 for t in self.executor._threads:
220 for t in executor._threads:
226 threads = executor._threads
237 threads = executor._threads
248 threads = executor._threads
|
| /external/tensorflow/tensorflow/contrib/training/python/training/ |
| D | bucket_ops_test.py | 84 self._threads = None
95 self._threads = queue_runner_impl.start_queue_runners(coord=self._coord)
101 self._coord.join(self._threads)
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 349 self.assertEqual(len(self.executor._threads), 3)
351 for t in self.executor._threads:
360 for t in executor._threads:
366 threads = executor._threads
376 threads = executor._threads
386 threads = executor._threads
|
| D | test_asynchat.py | 107 self._threads = support.threading_setup()
110 support.threading_cleanup(*self._threads)
|
| D | test_threading.py | 77 self._threads = test.support.threading_setup()
80 test.support.threading_cleanup(*self._threads)
|
| D | lock_tests.py | 70 self._threads = support.threading_setup()
73 support.threading_cleanup(*self._threads)
|
| /external/ltp/testcases/realtime/include/ |
| D | librttest.h | 81 struct list_head _threads; member
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | test_util.py | 1524 self._threads = []
1547 for thread in self._threads:
1954 self._threads.append(ret)
|