| /external/valgrind/main/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);
|
| 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
|
| tls.c | 90 pthread_t threads[NTESTS*2]; local
96 pthread_create(&threads[curthread++], NULL, tls_ptr, (void *)&tests[i]);
97 pthread_create(&threads[curthread++], NULL, tls_ptr, (void *)&tests[i]);
101 pthread_join(threads[i], NULL);
|
| /system/extras/tests/bionic/libc/common/ |
| test_pthread_once.c | 65 pthread_t threads[N_THREADS]; local
69 if (pthread_create( &threads[nn], NULL, thread_function, (void*)(long int)nn) < 0) {
76 if (pthread_join(threads[nn], NULL)) {
|
| test_pthread_getcpuclockid.c | 73 pthread_t threads[MAX_THREADS]; local
79 pthread_create( &threads[nn], &attr, thread_func, (void*)nn );
83 pthread_join( threads[nn], &dummy );
|
| /development/tools/emulator/opengl/host/libs/libOpenglRender/ |
| RenderServer.cpp | 65 RenderThreadsSet threads; local
101 // remove from the threads list threads which are
104 for (RenderThreadsSet::iterator n,t = threads.begin();
105 t != threads.end();
115 threads.erase(t);
120 threads.insert(rt);
126 // Wait for all threads to finish
128 for (RenderThreadsSet::iterator t = threads.begin();
129 t != threads.end()
[all...] |
| /external/chromium/base/threading/ |
| thread_local_storage_unittest.cc | 71 // threads that set the TLS, while the destructor cleans it up.
72 // After the threads finish, verify that the value is cleaned up.
76 DelegateSimpleThread* threads[kNumThreads]; local
80 // Spawn the threads.
84 threads[index] = new DelegateSimpleThread(thread_delegates[index],
86 threads[index]->Start();
89 // Wait for the threads to finish.
91 threads[index]->Join();
92 delete threads[index];
|
| /external/chromium/chrome/browser/net/ |
| chrome_net_log_unittest.cc | 42 // Only triggered once all threads have been created, to make it much less
57 ChromeNetLogTestThread threads[kThreads]; local
60 threads[i].Init(&log);
61 threads[i].Start();
65 threads[i].ReallyStart();
68 threads[i].Join();
|
| /external/valgrind/main/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
86 r= pthread_create(&threads[i], NULL, child, &id_arg[i]);
91 pthread_join(threads[i], NULL)
[all...] |
| /sdk/emulator/qtools/ |
| dmtrace.h | 57 std::vector<ThreadRecord*> *threads; member in class:DmTrace
|
| /external/libvpx/vpx/ |
| vpx_decoder.h | 94 unsigned int threads; /**< Maximum number of threads to use, default 1 */ member in struct:vpx_codec_dec_cfg
|
| /libcore/luni/src/test/java/org/apache/harmony/xnet/provider/jsse/ |
| 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/chromium/testing/gtest/test/ |
| gtest_stress_test.cc | 33 // used in a large number of threads concurrently.
62 // How many threads to create?
105 // RecordProperty() should interact safely with other threads as well.
126 // Tests using SCOPED_TRACE() and Google Test assertions in many threads
130 scoped_ptr<ThreadWithParam<int> > threads[kThreadCount]; local
133 threads[i].reset(new ThreadWithParam<int>(&ManyAsserts,
139 // Blocks until all the threads are done.
141 threads[i]->Join();
206 // This statement should succeed, because failures in all threads are
225 // This statement should succeed, because failures in all threads ar
[all...] |
| /libcore/luni/src/test/java/tests/security/ |
| SecureRandomTest.java | 78 int threads = 2; local
79 ExecutorService executor = Executors.newFixedThreadPool(threads);
81 for (int t = 0; t < threads; t++) {
92 for (int i = 0; i < threads; i++) {
|
| /packages/apps/Mms/tests/src/com/android/mms/ |
| RecyclerTest.java | 26 import android.provider.Telephony.Threads;
43 * Bang on the recycler and test it getting called simultaneously from two different threads
51 * Bang on the recycler and test it getting called simultaneously from two different threads
68 Threads.CONTENT_URI.buildUpon().appendQueryParameter("simple", "true").build();
70 Threads._ID, Threads.DATE, Threads.MESSAGE_COUNT, Threads.RECIPIENT_IDS,
71 Threads.SNIPPET, Threads.SNIPPET_CHARSET, Threads.READ, Threads.ERROR
241 ArrayList<Thread> threads = new ArrayList<Thread>(THREAD_COUNT); local
[all...] |
| /external/bluetooth/glib/tests/ |
| onceinit.c | 91 g_usleep (25 * 1000); /* waste time for multiple threads to wait */
115 GThread *threads[N_THREADS]; local
125 /* setup threads */
129 /* start multiple threads for initializer3() */
132 threads[i] = g_thread_create (tmain_call_initializer3, 0, FALSE, NULL);
136 /* loop until all threads passed the call to initializer3() */
145 /* call multiple (unoptimized) initializers from multiple threads */
152 g_usleep (50 * 1000); /* wait for all 5 threads to complete */
|
| slice-test.c | 275 GThread **threads; local
280 g_print ("Starting %d threads allocating random blocks <= %u bytes with seed=%s using %s%s\n", n_threads, prime_size, strseed, mode, emode);
282 threads = g_alloca (sizeof(GThread*) * n_threads);
285 threads[i] = g_thread_create_full (test_sliced_mem_thread, seedp, 0, TRUE, FALSE, 0, NULL);
290 threads[i] = g_thread_create_full (test_memchunk_thread, seedp, 0, TRUE, FALSE, 0, NULL);
293 g_thread_join (threads[i]);
|
| /external/chromium/base/metrics/ |
| stats_table_unittest.cc | 51 slot_id = table.RegisterThread("too many threads");
69 // CounterMixed will be incremented by odd numbered threads and
70 // decremented by even threads.
108 // Create a few threads and have them poke on their counters.
121 // Spin up a set of threads to go bang on the various counters.
122 // After we join the threads, we'll make sure the counters
124 StatsTableThread* threads[kMaxThreads]; local
126 // Spawn the threads.
128 threads[index] = new StatsTableThread("MultipleThreadsTest", index);
129 threads[index]->Start()
[all...] |
| /external/chromium/base/ |
| time_win_unittest.cc | 69 // 2) Create N threads
70 // 3) Start the threads
84 HANDLE threads[kThreads]; local
89 threads[index] = reinterpret_cast<HANDLE>(
92 EXPECT_NE((HANDLE)NULL, threads[index]);
98 // Wait for threads to finish
100 DWORD rv = WaitForSingleObject(threads[index], INFINITE);
|
| /external/protobuf/src/google/protobuf/stubs/ |
| once_unittest.cc | 209 scoped_ptr<TestThread> threads[4]; local
212 threads[i].reset(RunInitOnceInNewThread());
215 threads[i]->Join();
226 scoped_ptr<TestThread> threads[8]; local
231 threads[i].reset(RunInitOnceInNewThread());
234 threads[i].reset(RunInitRecursiveOnceInNewThread());
246 threads[i]->Join();
|
| /external/qemu/distrib/sdl-1.2.12/src/thread/ |
| SDL_thread.c | 32 /* The array of threads currently active in the application
55 clean up threads here. If any threads are still running after this call,
73 If the very first threads are created simultaneously, then
85 /* Expand the list of threads, if necessary */
91 SDL_Thread **threads; local
92 threads = (SDL_Thread **)SDL_realloc(SDL_Threads,
93 (SDL_maxthreads+ARRAY_CHUNKSIZE)*(sizeof *threads));
94 if ( threads == NULL ) {
99 SDL_Threads = threads;
[all...] |
| /external/qemu/distrib/sdl-1.2.12/src/thread/amigaos/ |
| SDL_thread.c | 32 /* The array of threads currently active in the application
51 clean up threads here. If any threads are still running after this call,
62 SDL_Thread **threads; local
65 If the very first threads are created simultaneously, then
77 /* Expand the list of threads, if necessary */
83 threads=(SDL_Thread **)SDL_malloc((SDL_maxthreads+ARRAY_CHUNKSIZE)*
84 (sizeof *threads));
85 if ( threads == NULL ) {
89 SDL_memcpy(threads, SDL_Threads, SDL_numthreads*(sizeof *threads))
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| ConcurrentCloseTest.java | 127 // We want to test that we unblock *all* the threads blocked on a socket, not just one.
131 final ArrayList<Thread> threads = new ArrayList<Thread>(); local
149 threads.add(t);
151 for (Thread t : threads) {
155 for (Thread t : threads) {
|
| /libcore/luni/src/test/java/tests/support/ |
| ThreadPool.java | 79 Thread[] threads = new Thread[activeCount()]; local
80 int count = enumerate(threads);
83 threads[i].join();
|
| /system/media/wilhelm/tests/sandbox/ |
| multithread.c | 17 // Multiple threads create and destroy objects
37 pthread_t threads[MAX_THREAD]; variable
128 // create threads
155 ok = pthread_create(&threads[i], (const pthread_attr_t *) NULL, thread_start,
171 // signal threads that they should exit
183 // now wait for the threads to actually exit
185 ok = pthread_join(threads[i], NULL);
|
