| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/VirtualMachine/ |
| Resume002Debuggee.java | 30 // The method used to suspend threads on breakpoint.
59 // Create tested threads.
60 Thread[] threads = new Thread[THREAD_COUNT]; local
61 for (int i = 0; i < threads.length; ++i) {
62 threads[i] = new ResumeThread(i);
65 // Start threads.
66 logWriter.println("Starting threads");
67 for (Thread t : threads) {
71 // Wait for all tested threads to finish.
72 logWriter.println("Waiting end of threads");
[all...] |
| /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/demos/mandelbrot/ |
| mandelbrot.h | 45 MandelbrotThread **threads; member in class:MandelbrotWidget
60 threads = new MandelbrotThread*[threadcount];
61 for(int th = 0; th < threadcount; th++) threads[th] = new MandelbrotThread(this, th);
66 for(int th = 0; th < threadcount; th++) delete threads[th];
67 delete[] threads;
|
| /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/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/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
|
| 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);
|
| thread-exits.stdout.exp | 2 creating threads...
|
| /external/eigen/bench/tensors/ |
| contraction_benchmarks_cpu.cc | 7 #define CREATE_THREAD_POOL(threads) \
8 Eigen::ThreadPool pool(threads); \
9 Eigen::ThreadPoolDevice device(&pool, threads);
12 // Contractions for number of threads ranging from 1 to 32
15 static void BM_##Contraction##_##D1##x##D2##x##D3(int iters, int Threads) { \
17 CREATE_THREAD_POOL(Threads); \
|
| /external/libvpx/libvpx/test/ |
| vpxdec.sh | 86 for threads in 2 3 4 5 6 7 8; do
87 vpxdec "${VP9_FPM_WEBM_FILE}" --summary --noblit --threads=$threads \
|
| /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);
|
| /external/skia/src/core/ |
| SkTaskGroup.cpp | 46 SkTaskGroup::Enabler::Enabler(int threads) {
47 if (threads) {
48 fThreadPool = SkExecutor::MakeLIFOThreadPool(threads);
|
| SkExecutor.cpp | 62 // An SkThreadPool is an executor that runs work on a fixed pool of OS threads.
66 explicit SkThreadPool(int threads) {
67 for (int i = 0; i < threads; i++) {
89 // Tell the Loop() threads to pick it up.
134 std::unique_ptr<SkExecutor> SkExecutor::MakeFIFOThreadPool(int threads) {
136 return skstd::make_unique<SkThreadPool<WorkList>>(threads > 0 ? threads : num_cores());
138 std::unique_ptr<SkExecutor> SkExecutor::MakeLIFOThreadPool(int threads) {
140 return skstd::make_unique<SkThreadPool<WorkList>>(threads > 0 ? threads : num_cores())
[all...] |
| /external/skia/tests/ |
| TLSTest.cpp | 36 std::thread threads[8]; local
38 for (auto& thread : threads) {
41 for (auto& thread : threads) {
|
| /external/skqp/src/core/ |
| SkTaskGroup.cpp | 46 SkTaskGroup::Enabler::Enabler(int threads) {
47 if (threads) {
48 fThreadPool = SkExecutor::MakeLIFOThreadPool(threads);
|
| SkExecutor.cpp | 62 // An SkThreadPool is an executor that runs work on a fixed pool of OS threads.
66 explicit SkThreadPool(int threads) {
67 for (int i = 0; i < threads; i++) {
89 // Tell the Loop() threads to pick it up.
134 std::unique_ptr<SkExecutor> SkExecutor::MakeFIFOThreadPool(int threads) {
136 return skstd::make_unique<SkThreadPool<WorkList>>(threads > 0 ? threads : num_cores());
138 std::unique_ptr<SkExecutor> SkExecutor::MakeLIFOThreadPool(int threads) {
140 return skstd::make_unique<SkThreadPool<WorkList>>(threads > 0 ? threads : num_cores())
[all...] |
| /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);
|
| /art/test/114-ParallelGC/src/ |
| Main.java | 38 Thread[] threads = new Thread[THREAD_COUNT]; local
40 // This barrier is used to synchronize the threads starting to allocate.
43 CyclicBarrier startBarrier = new CyclicBarrier(threads.length);
45 for (int i = 0; i < threads.length; i++) {
46 threads[i] = new Thread(new Main(startBarrier));
47 threads[i].start();
50 // Wait for the threads to finish.
51 for (Thread thread : threads) {
|
| /art/test/ti-agent/ |
| suspension_helper.cc | 50 std::vector<jthread> threads(CopyToVector(env, thr));
54 jintArray ret = env->NewIntArray(threads.size());
60 jvmti_env->ResumeThreadList(threads.size(),
61 threads.data(),
71 std::vector<jthread> threads(CopyToVector(env, thrs));
75 jintArray ret = env->NewIntArray(threads.size());
81 jvmti_env->SuspendThreadList(threads.size(),
82 threads.data(),
|
| /external/autotest/client/tests/monotonic_time/src/ |
| Makefile | 8 SRCS= time_test.c cpuset.c threads.c logging.c
9 HDRS= spinlock.h cpuset.h threads.h logging.h
|
| /external/linux-kselftest/tools/testing/selftests/powerpc/math/ |
| vmx_signal.c | 32 * worker threads
99 int i, j, rc, threads; local
103 threads = sysconf(_SC_NPROCESSORS_ONLN) * THREAD_FACTOR;
104 tids = malloc(threads * sizeof(pthread_t));
108 threads_starting = threads;
109 for (i = 0; i < threads; i++) {
115 printf("\tWaiting for %d workers to start... %d", threads, threads_starting);
123 printf("\tSending signals to all threads %d times...", ITERATIONS);
125 for (j = 0; j < threads; j++) {
134 for (i = 0; i < threads; i++)
[all...] |
| /external/ltp/testcases/open_posix_testsuite/functional/ |
| Makefile | 13 @find */ -name 'Makefile*' | grep -v threads/Makefile | xargs rm -f
|
| /external/webrtc/webrtc/test/channel_transport/ |
| udp_socket_wrapper_unittest.cc | 53 uint8_t threads = 1; local
54 UdpSocketManager* mgr = UdpSocketManager::Create(id, threads);
|
