| /external/linux-kselftest/tools/testing/selftests/powerpc/math/ |
| fpu_preempt.c | 12 * no way to be sure preemption happened so this test just uses many threads
32 * worker threads
61 int i, rc, threads; local
64 threads = sysconf(_SC_NPROCESSORS_ONLN) * THREAD_FACTOR;
65 tids = malloc((threads) * sizeof(pthread_t));
69 threads_starting = threads;
70 for (i = 0; i < threads; i++) {
92 for (i = 0; i < threads; i++) {
|
| vmx_preempt.c | 12 * no way to be sure preemption happened so this test just uses many threads
32 * worker threads
61 int i, rc, threads; local
64 threads = sysconf(_SC_NPROCESSORS_ONLN) * THREAD_FACTOR;
65 tids = malloc(threads * sizeof(pthread_t));
69 threads_starting = threads;
70 for (i = 0; i < threads; i++) {
92 for (i = 0; i < threads; i++) {
|
| /external/ltp/lib/newlib_tests/ |
| test15.c | 39 #define THREADS 64
94 if (i < THREADS - 1) {
108 pthread_t threads[THREADS + 1]; local
111 m = SAFE_MMAP(NULL, sizeof(*m) * THREADS,
115 seq_n = &((m + THREADS / 2)->seq_n);
117 pthread_create(&threads[THREADS], NULL, mem_spam, NULL);
118 for (i = THREADS - 1; i >= 0; i--)
119 pthread_create(&threads[i], NULL, worker_load_store, (void *)i)
[all...] |
| /external/ltp/testcases/kernel/sched/pthreads/ |
| pth_str01.h | 26 pthread_t *threads; /* dynamic array of thread */ member in struct:child_info
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_atfork/ |
| 1-2.c | 91 pthread_t threads[3]; variable
98 threads[0] = pthread_self();
103 threads[1] = pthread_self();
108 threads[2] = pthread_self();
139 if (!pthread_equal(ch, threads[0])) {
144 if (!pthread_equal(pthread_self(), threads[2])) {
153 if (!pthread_equal(ch, threads[0])) {
158 if (!pthread_equal(pthread_self(), threads[1])) {
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_mutex_lock/ |
| 1-1.c | 16 * -- Create N threads. Each is looped M times to acquire the mutex,
42 pthread_t threads[THREAD_NUM]; local
48 /* Create threads */
49 fprintf(stderr, "Creating %d threads\n", THREAD_NUM);
51 rc = pthread_create(&threads[i], &pta, f1, NULL);
53 /* Wait to join all threads */
55 pthread_join(threads[i], NULL);
61 fprintf(stderr, "Using %d threads and each loops %d times\n",
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_mutex_unlock/ |
| 2-1.c | 9 * If there are threads blocked on the mutex object referenced by 'mutex' when
19 * -- Create N threads. Each is looped M times to acquire the mutex,
44 pthread_t threads[THREAD_NUM]; local
46 /* Create threads */
47 fprintf(stderr, "Creating %d threads\n", THREAD_NUM);
49 rc = pthread_create(&threads[i], NULL, func, NULL);
51 /* Wait to join all threads */
53 pthread_join(threads[i], NULL);
58 fprintf(stderr, "Using %d threads and each loops %d times\n",
|
| /external/mesa3d/src/gallium/tests/unit/ |
| pipe_barrier_test.c | 32 * The test succeeds if no thread exits before all the other threads reach
49 static pipe_thread threads[NUM_THREADS]; variable
115 threads[i] = pipe_thread_create(thread_function, (void *) &thread_ids[i]);
119 pipe_thread_wait(threads[i]);
|
| /external/mockito/src/test/java/org/mockitoutil/ |
| ConcurrentTesting.java | 29 List<Thread> threads = new LinkedList<Thread>(); local
33 threads.add(t);
36 for (Thread t : threads) {
|
| /external/perfetto/src/traced/probes/ |
| process_stats_data_source_unittest.cc | 102 const auto& threads = packet->process_tree().threads(); local
111 ASSERT_EQ(threads.Get(tid_idx).tid(), tid);
112 ASSERT_EQ(threads.Get(tid_idx).tgid(), pid);
113 ASSERT_EQ(threads.Get(tid_idx).name(), "thread_" + std::to_string(tid));
|
| /external/skia/tests/ |
| StringTest.cpp | 277 std::thread threads[5]; local
278 for (auto& thread : threads) {
284 for (auto& thread : threads) {
|
| /external/skqp/tests/ |
| StringTest.cpp | 296 std::thread threads[5]; local
297 for (auto& thread : threads) {
303 for (auto& thread : threads) {
|
| /external/smali/smalidea/src/main/java/org/jf/smalidea/debugging/value/ |
| LazyThreadGroupReference.java | 68 @Override public List<ThreadReference> threads() { method in class:LazyThreadGroupReference
69 return getValue().threads();
|
| /external/stressapptest/src/ |
| findmask.c | 129 pthread_t threads[NUM_THREADS]; local
134 pthread_create(&threads[i], 0, thread_func, (void*)i);
137 pthread_join(threads[i], 0);
|
| /external/valgrind/helgrind/tests/ |
| tc21_pthonce.c | 15 * "Using POSIX Threads: Programming with Pthreads"
25 * A program spawns multiple threads and each one tries to
31 * exit of the threads using the pthread_join() operation.
43 /* With more than 2 threads, the precise error reports vary between
45 simple and just have 2 threads and so just 1 race. */
53 /* This is a hack: delay threads except the first enough so as to
54 ensure threads[0] gets to the pthread_once call first. This is so
80 pthread_t threads[NUM_THREADS]; local
87 r= pthread_create(&threads[i], NULL, child, &id_arg[i]);
92 pthread_join(threads[i], NULL)
[all...] |
| /external/valgrind/none/tests/ |
| pth_cvsimple.c | 4 * "Using POSIX Threads: Programming with Pthreads"
65 pthread_t threads[3]; local
67 pthread_create(&threads[0], NULL, watch_count, NULL);
69 pthread_create(&threads[1], NULL, inc_count, NULL);
70 pthread_create(&threads[2], NULL, inc_count, NULL);
73 pthread_join(threads[i], NULL);
77 // inc_count threads could fully run before watch_count begins, and so
|
| /external/webrtc/webrtc/libjingle/xmllite/ |
| xmlelement_unittest.cc | 247 std::vector<rtc::Thread*> threads; local
249 threads.push_back(
251 threads[i]->Start();
255 threads[i]->Stop();
256 delete threads[i];
|
| /frameworks/minikin/tests/stresstest/ |
| MultithreadTest.cpp | 63 // Wait until all threads are created.
91 std::vector<std::thread> threads; local
95 threads.reserve(NUM_THREADS);
97 threads.emplace_back(&thread_main, i);
103 for (auto& thread : threads) {
|
| /frameworks/ml/nn/runtime/test/ |
| TestOpenmpSettings.cpp | 67 std::vector<std::thread> threads; local
72 threads.push_back(std::thread([sleepFor]() {
87 std::for_each(threads.begin(), threads.end(), [](std::thread& t) {
|
| /prebuilts/misc/windows/sdl2/test/ |
| testlock.c | 27 static SDL_Thread *threads[6]; variable
61 SDL_WaitThread(threads[i], NULL);
84 /* If this sleep isn't done, then threads may starve */
121 if ((threads[i] = SDL_CreateThread(Run, name, NULL)) == NULL)
|
| testsem.c | 82 SDL_Thread *threads[NUM_THREADS]; local
105 SDL_Log("Running %d threads, semaphore value = %d\n", NUM_THREADS,
107 /* Create all the threads */
111 threads[i] = SDL_CreateThread(ThreadFunc, name, (void *) i);
117 /* Wait for all threads to finish */
118 SDL_Log("Waiting for threads to finish\n");
121 SDL_WaitThread(threads[i], NULL);
123 SDL_Log("Finished waiting for threads\n");
|
| torturethread.c | 80 SDL_Thread *threads[NUMTHREADS]; local
97 threads[i] = SDL_CreateThread(ThreadFunc, name, (void*) (uintptr_t) i);
99 if (threads[i] == NULL) {
110 SDL_WaitThread(threads[i], NULL);
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++abi/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 ] );
|
| /system/core/libunwindstack/tests/ |
| MapInfoGetElfTest.cpp | 375 std::vector<std::thread*> threads; local
379 // Create all of the threads and have them do the GetElf at the same time
389 threads.push_back(thread);
393 // Set them all going and wait for the threads to finish.
395 for (auto thread : threads) {
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| MoreExecutorsDirectExecutorBenchmark.java | 66 Set<Thread> threads = new HashSet<Thread>(); field in class:MoreExecutorsDirectExecutorBenchmark
80 threads.add(thread);
85 for (Thread thread : threads) {
88 threads.clear();
106 for (Thread thread : threads) {
|
