| /external/pthreadpool/src/ |
| D | pthreads.c | 230 struct pthreadpool* pthreadpool_create(size_t threads_count) { in pthreadpool_create() argument
237 if (threads_count == 0) { in pthreadpool_create()
239 threads_count = cpuinfo_get_processors_count(); in pthreadpool_create()
241 threads_count = (size_t) sysconf(_SC_NPROCESSORS_ONLN); in pthreadpool_create()
244 if (threads_count >= 8) { in pthreadpool_create()
245 threads_count = 8; in pthreadpool_create()
252 threads_count = (size_t) system_info.dwNumberOfProcessors; in pthreadpool_create()
258 struct pthreadpool* threadpool = pthreadpool_allocate(threads_count); in pthreadpool_create()
262 threadpool->threads_count = fxdiv_init_size_t(threads_count); in pthreadpool_create()
263 for (size_t tid = 0; tid < threads_count; tid++) { in pthreadpool_create()
[all …]
|
| D | gcd.c | 45 struct pthreadpool* pthreadpool_create(size_t threads_count) { in pthreadpool_create() argument
46 if (threads_count == 0) { in pthreadpool_create()
57 threads_count = (size_t) threads; in pthreadpool_create()
60 struct pthreadpool* threadpool = pthreadpool_allocate(threads_count); in pthreadpool_create()
64 threadpool->threads_count = fxdiv_init_size_t(threads_count); in pthreadpool_create()
65 for (size_t tid = 0; tid < threads_count; tid++) { in pthreadpool_create()
70 if (threads_count > 1) { in pthreadpool_create()
101 const struct fxdiv_divisor_size_t threads_count = threadpool->threads_count; in pthreadpool_parallelize() local
108 const struct fxdiv_result_size_t range_params = fxdiv_divide_size_t(linear_range, threads_count); in pthreadpool_parallelize()
110 for (size_t tid = 0; tid < threads_count.value; tid++) { in pthreadpool_parallelize()
[all …]
|
| D | fastpath.c | 35 const size_t threads_count = threadpool->threads_count.value; in pthreadpool_thread_parallelize_1d_fastpath() local
36 const size_t range_threshold = -threads_count; in pthreadpool_thread_parallelize_1d_fastpath()
46 for (size_t tid = modulo_decrement(thread_number, threads_count); in pthreadpool_thread_parallelize_1d_fastpath()
48 tid = modulo_decrement(tid, threads_count)) in pthreadpool_thread_parallelize_1d_fastpath()
80 const size_t threads_count = threadpool->threads_count.value; in pthreadpool_thread_parallelize_1d_with_uarch_fastpath() local
81 const size_t range_threshold = -threads_count; in pthreadpool_thread_parallelize_1d_with_uarch_fastpath()
91 for (size_t tid = modulo_decrement(thread_number, threads_count); in pthreadpool_thread_parallelize_1d_with_uarch_fastpath()
93 tid = modulo_decrement(tid, threads_count)) in pthreadpool_thread_parallelize_1d_with_uarch_fastpath()
116 const size_t threads_count = threadpool->threads_count.value; in pthreadpool_thread_parallelize_1d_tile_1d_fastpath() local
117 const size_t range_threshold = -threads_count; in pthreadpool_thread_parallelize_1d_tile_1d_fastpath()
[all …]
|
| D | portable-api.c | 29 return threadpool->threads_count.value; in pthreadpool_get_threads_count()
47 const size_t threads_count = threadpool->threads_count.value; in thread_parallelize_1d() local
48 for (size_t tid = modulo_decrement(thread_number, threads_count); in thread_parallelize_1d()
50 tid = modulo_decrement(tid, threads_count)) in thread_parallelize_1d()
87 const size_t threads_count = threadpool->threads_count.value; in thread_parallelize_1d_with_uarch() local
88 for (size_t tid = modulo_decrement(thread_number, threads_count); in thread_parallelize_1d_with_uarch()
90 tid = modulo_decrement(tid, threads_count)) in thread_parallelize_1d_with_uarch()
123 const size_t threads_count = threadpool->threads_count.value; in thread_parallelize_1d_tile_1d() local
124 for (size_t tid = modulo_decrement(thread_number, threads_count); in thread_parallelize_1d_tile_1d()
126 tid = modulo_decrement(tid, threads_count)) in thread_parallelize_1d_tile_1d()
[all …]
|
| D | windows.c | 134 struct pthreadpool* pthreadpool_create(size_t threads_count) { in pthreadpool_create() argument
135 if (threads_count == 0) { in pthreadpool_create()
139 threads_count = (size_t) system_info.dwNumberOfProcessors; in pthreadpool_create()
142 struct pthreadpool* threadpool = pthreadpool_allocate(threads_count); in pthreadpool_create()
146 threadpool->threads_count = fxdiv_init_size_t(threads_count); in pthreadpool_create()
147 for (size_t tid = 0; tid < threads_count; tid++) { in pthreadpool_create()
153 if (threads_count > 1) { in pthreadpool_create()
171 …pthreadpool_store_relaxed_size_t(&threadpool->active_threads, threads_count - 1 /* caller thread *… in pthreadpool_create()
174 for (size_t tid = 1; tid < threads_count; tid++) { in pthreadpool_create()
215 const struct fxdiv_divisor_size_t threads_count = threadpool->threads_count; in pthreadpool_parallelize() local
[all …]
|
| D | memory.c | 23 size_t threads_count) in pthreadpool_allocate() argument
25 assert(threads_count >= 1); in pthreadpool_allocate()
27 …const size_t threadpool_size = sizeof(struct pthreadpool) + threads_count * sizeof(struct thread_i… in pthreadpool_allocate()
58 …const size_t threadpool_size = sizeof(struct pthreadpool) + threadpool->threads_count.value * size… in pthreadpool_deallocate()
|
| D | threadpool-object.h | 702 struct fxdiv_divisor_size_t threads_count; member
713 size_t threads_count);
|
| D | shim.c | 17 struct pthreadpool* pthreadpool_create(size_t threads_count) { in pthreadpool_create() argument
18 if (threads_count <= 1) { in pthreadpool_create()
|
| /external/ruy/ruy/ |
| D | thread_pool.cc | 198 void ThreadPool::CreateThreads(int threads_count) { in CreateThreads() argument
199 RUY_DCHECK_GE(threads_count, 0); in CreateThreads()
200 unsigned int unsigned_threads_count = threads_count; in CreateThreads()
204 counter_to_decrement_when_ready_.Reset(threads_count - threads_.size()); in CreateThreads()
|
| D | thread_pool.h | 92 void CreateThreads(int threads_count);
|
| /external/pthreadpool/examples/ |
| D | addition.c | 27 const size_t threads_count = pthreadpool_get_threads_count(threadpool); in main() local
28 printf("Created thread pool with %zu threads\n", threads_count); in main()
|
| /external/pthreadpool/ |
| D | README.md | 39 const size_t threads_count = pthreadpool_get_threads_count(threadpool);
40 printf("Created thread pool with %zu threads\n", threads_count);
|
| /external/webrtc/media/sctp/ |
| D | sctp_transport_reliability_unittest.cc | 303 explicit ThreadPool(size_t threads_count) : random_(42) { in ThreadPool() argument
304 RTC_DCHECK(threads_count > 0); in ThreadPool()
305 threads_.reserve(threads_count); in ThreadPool()
306 for (size_t i = 0; i < threads_count; i++) { in ThreadPool()
|
| /external/autotest/client/site_tests/platform_PrinterPpds/ |
| D | platform_PrinterPpds.py | 86 threads_count=8): argument
108 threads_count)
|
| /external/pthreadpool/include/ |
| D | pthreadpool.h | 77 pthreadpool_t pthreadpool_create(size_t threads_count);
|