| /external/webrtc/webrtc/test/channel_transport/ |
| udp_socket_manager_unittest.cc | 28 uint8_t threads = 1; local
29 UdpSocketManager* mgr = UdpSocketManager::Create(id, threads);
31 EXPECT_FALSE(mgr->Init(id, threads))
40 uint8_t threads = 1; local
41 UdpSocketManager* mgr = UdpSocketManager::Create(id, threads);
65 uint8_t threads = 1;
66 UdpSocketManager* mgr = UdpSocketManager::Create(id, threads);
|
| udp_socket_wrapper_unittest.cc | 53 uint8_t threads = 1; local
54 UdpSocketManager* mgr = UdpSocketManager::Create(id, threads);
|
| /art/test/304-method-tracing/src/ |
| Main.java | 31 ArrayList<Thread> threads = new ArrayList<Thread>(); local
33 threads.add(new Thread(new ThreadRunnable(), "TestThread-" + i));
36 for (Thread t : threads) {
40 for (Thread t : threads) {
|
| /external/mockito/src/test/java/org/mockitousage/bugs/ |
| ShouldNotDeadlockAnswerExecutionTest.java | 25 ExecutorService threads = Executors.newCachedThreadPool(); local
32 // execute verySlowMethod twice in separate threads
34 threads.execute(new ServiceRunner(service));
35 threads.execute(new ServiceRunner(service));
37 // waiting for threads to finish
39 threads.shutdown();
41 if (!threads.awaitTermination(1000, TimeUnit.MILLISECONDS)) {
42 // threads were timed-out
51 ExecutorService threads = Executors.newCachedThreadPool(); local
59 // execute verySlowMethod twice in separate threads
[all...] |
| /art/test/149-suspend-all-stress/src/ |
| Main.java | 24 final Thread[] threads = new Thread[numberOfThreads]; local
25 for (int t = 0; t < threads.length; t++) {
26 threads[t] = new Thread(new Main());
27 threads[t].start();
29 for (Thread t : threads) {
|
| /development/tools/bugreport/src/com/android/bugreport/bugreport/ |
| ProcessInfo.java | 36 * The threads in the process
38 public HashMap<Integer,ThreadInfo> threads = new HashMap<Integer,ThreadInfo>(); field in class:ProcessInfo
|
| /external/compiler-rt/lib/tsan/tests/rtl/ |
| tsan_thread.cc | 50 pthread_t threads[kAlive] = {}; local
52 if (threads[i % kAlive])
53 pthread_join(threads[i % kAlive], 0);
54 pthread_create(&threads[i % kAlive], 0, thread_alot_func, 0);
57 pthread_join(threads[i], 0);
|
| /external/linux-kselftest/tools/testing/selftests/powerpc/tm/ |
| tm-vmx-unavail.c | 91 int threads; local
98 threads = sysconf(_SC_NPROCESSORS_ONLN) * 4;
99 thread = malloc(sizeof(pthread_t)*threads);
103 for (uint64_t i = 0; i < threads; i++)
106 for (uint64_t i = 0; i < threads; i++)
|
| /external/ltp/lib/newlib_tests/ |
| test08.c | 25 #define THREADS 10
31 pthread_barrier_init(&barrier, NULL, THREADS);
40 /* Avoid subsequent threads to enter the cleanup */
61 pthread_t threads[THREADS]; local
63 for (i = 0; i < THREADS; i++)
64 pthread_create(threads+i, NULL, worker, (void*)i);
66 for (i = 0; i < THREADS; i++) {
68 pthread_join(threads[i], NULL);
|
| test09.c | 23 #define THREADS 64
42 pthread_t threads[THREADS]; local
44 for (i = 0; i < THREADS; i++)
45 pthread_create(threads+i, NULL, worker, (void *)i);
47 for (i = 0; i < THREADS; i++) {
49 pthread_join(threads[i], NULL);
52 if (atomic == THREADS * ITERATIONS)
|
| /external/perf_data_converter/src/quipper/ |
| dso.h | 31 std::unordered_set<uint64_t> threads; member in struct:quipper::DSOInfo
|
| /external/skia/tests/ |
| TLSTest.cpp | 36 std::thread threads[8]; local
38 for (auto& thread : threads) {
41 for (auto& thread : threads) {
|
| /external/skqp/tests/ |
| TLSTest.cpp | 36 std::thread threads[8]; local
38 for (auto& thread : threads) {
41 for (auto& thread : threads) {
|
| /external/valgrind/drd/tests/ |
| concurrent_close.cpp | 12 /* Happens with two threads also */
32 pthread_t threads[THREAD_COUNT]; local
37 r = pthread_create(&threads[i], &attr, thread, 0);
45 r = pthread_join(threads[i], 0);
|
| /external/valgrind/none/tests/ |
| pth_once.c | 4 * "Using POSIX Threads: Programming with Pthreads"
14 * A program spawns multiple threads and each one tries to
20 * exit of the threads using the pthread_join() operation.
57 pthread_t threads[NUM_THREADS]; local
65 if (( rtn = pthread_create(&threads[thread_num],
76 pthread_join(threads[thread_num], NULL);
|
| /frameworks/native/services/surfaceflinger/tests/ |
| Stress_test.cpp | 41 std::vector<std::thread> threads; local
43 threads.push_back(std::thread(do_stress));
45 for (auto& thread : threads) {
|
| /art/test/925-threadgroups/ |
| threadgroups.cc | 35 // // Returns an array where element 0 is an array of threads and element 1 is an array of groups.
92 jthread* threads; local
98 &threads,
107 // Threads.
109 return threads[index];
122 jvmti_env->Deallocate(reinterpret_cast<unsigned char*>(threads));
|
| /development/tools/bugreport/src/com/android/bugreport/stacks/ |
| ProcessSnapshot.java | 28 public ArrayList<ThreadSnapshot> threads = new ArrayList<ThreadSnapshot>(); field in class:ProcessSnapshot
43 final int N = that.threads.size();
45 this.threads.add(that.threads.get(i).clone());
58 * Compares the threads based on their tid.
68 for (ThreadSnapshot thread: this.threads) {
80 for (ThreadSnapshot thread: this.threads) {
91 for (ThreadSnapshot thread: this.threads) {
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| FileClientSessionCacheTest.java | 35 Thread[] threads = new Thread[10]; local
37 for (int i = 0; i < threads.length; i++) {
39 threads[i] = new Thread() {
48 for (Thread thread : threads) {
51 for (Thread thread : threads) {
|
| /external/eigen/unsupported/test/ |
| cxx11_runqueue.cpp | 158 // One thread (owner) calls PushFront/PopFront, other threads call PushBack/
165 std::vector<std::unique_ptr<std::thread>> threads; local
166 threads.emplace_back(new std::thread([&q, &total]() {
188 threads.emplace_back(new std::thread([&q, &total]() {
200 threads.emplace_back(new std::thread([&q, &total]() {
225 for (size_t i = 0; i < threads.size(); i++) threads[i]->join();
|
| /external/elfutils/tests/ |
| dwfl-proc-attach.c | 66 int *threads = (int *) thread_arg; local
69 (*threads)++;
78 /* Create two extra threads to iterate through. */
95 /* Did we see all 3 threads? */
96 int threads = 0; local
97 if (dwfl_getthreads (dwfl, thread_callback, &threads) != DWARF_CB_OK)
100 return (threads == 3) ? 0 : -1;
|
| /external/fio/t/ |
| memlock.c | 34 unsigned long mib, threads; local
39 printf("%s: <MiB per thread> <threads>\n", argv[0]);
44 threads = strtoul(argv[2], NULL, 10);
46 pthreads = calloc(threads, sizeof(pthread_t));
49 for (i = 0; i < threads; i++)
52 for (i = 0; i < threads; i++) {
|
| /external/guava/guava-tests/benchmark/com/google/common/collect/ |
| ConcurrentHashMultisetBenchmark.java | 50 @Param({"1", "2", "4", "8"}) int threads; field in class:ConcurrentHashMultisetBenchmark
66 Executors.newFixedThreadPool(threads, new ThreadFactoryBuilder().setDaemon(true).build());
90 List<Future<Long>> futures = Lists.newArrayListWithCapacity(threads);
91 for (int i = 0; i < threads; i++) {
196 * <p>If the data in the multiset is modified by any other threads during this
|
| /external/honggfuzz/ |
| honggfuzz.c | 186 pthread_t threads[hfuzz.threads.threadsMax]; local
189 fuzz_threadsStart(&hfuzz, threads);
202 if (ATOMIC_GET(hfuzz.threads.threadsFinished) >= hfuzz.threads.threadsMax) {
215 fuzz_threadsStop(&hfuzz, threads);
|
| /external/libcxxabi/test/ |
| test_exception_storage.pass.cpp | 45 std::__libcpp_thread_t threads [ NUMTHREADS ]; variable
52 // Make the threads, let them run, and wait for them to finish
54 std::__libcpp_thread_create ( threads + i, thread_code, (void *) (thread_globals + i));
56 std::__libcpp_thread_join ( &threads [ i ] );
|
