| /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 | 108 self._threads = []
125 self._threads.append(thread)
140 for thread in self._threads:
157 alive_threads = self._threads[:]
164 (len(alive_threads), len(self._threads)))
170 for thread in self._threads:
181 return any(t.isAlive() for t in self._threads)
202 for thread in (t for t in self._threads if t.isAlive()):
212 if any([t.isAlive() for t in self._threads]):
214 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/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 | 146 self._threads = set()
184 num_threads = len(self._threads)
194 self._threads.add(t)
228 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 | test_threading.py | 69 self._threads = test.test_support.threading_setup()
72 test.test_support.threading_cleanup(*self._threads)
|
| D | lock_tests.py | 63 self._threads = support.threading_setup()
66 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_httpservers.py | 74 self._threads = test_support.threading_setup()
84 test_support.threading_cleanup(*self._threads)
|
| D | test_file2k.py | 490 self._threads = test_support.threading_setup()
510 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/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 401 self.assertEqual(len(self.executor._threads), 3)
405 for t in self.executor._threads:
414 for t in executor._threads:
420 threads = executor._threads
435 threads = executor._threads
449 threads = executor._threads
459 threads = executor._threads
880 self.assertEqual(len(executor._threads), executor._max_workers)
890 self.assertEqual(len(executor._threads), 1)
|
| D | test_asynchat.py | 106 self._threads = support.threading_setup()
109 support.threading_cleanup(*self._threads)
|
| D | lock_tests.py | 76 self._threads = support.threading_setup()
79 support.threading_cleanup(*self._threads)
|
| D | test_threading.py | 78 self._threads = test.support.threading_setup()
81 test.support.threading_cleanup(*self._threads)
|
| D | test_httpservers.py | 67 self._threads = support.threading_setup()
78 support.threading_cleanup(*self._threads)
|
| /external/ltp/testcases/realtime/include/ |
| D | librttest.h | 81 struct list_head _threads; member
|
| /external/python/cpython3/Lib/asyncio/ |
| D | unix_events.py | 1341 self._threads = {}
1351 threads = [thread for thread in list(self._threads.values())
1363 threads = [thread for thread in list(self._threads.values())
1376 self._threads[pid] = thread
1412 self._threads.pop(expected_pid)
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | utils.py | 527 threads = list(watcher._threads.values())
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | test_util.py | 2043 self._threads = []
2085 for thread in self._threads:
2504 self._threads.append(ret)
|
| /external/python/cpython2/Doc/c-api/ |
| D | init.rst | 338 .. _threads:
|
| /external/python/cpython3/Doc/c-api/ |
| D | init.rst | 641 .. _threads:
|