/dports/science/lammps/lammps-stable_29Sep2021/lib/kokkos/core/src/HPX/ |
H A D | Kokkos_HPX_Task.hpp | 97 buffer.resize(num_worker_threads, 512); in execute_task() 101 latch num_tasks_remaining(num_worker_threads); in execute_task() 102 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() 104 for (int thread = 0; thread < num_worker_threads; ++thread) { in execute_task() 106 num_worker_threads]() { in execute_task() 115 Kokkos::Experimental::HPX(), num_worker_threads, 1), in execute_task() 232 buffer.resize(num_worker_threads, 512); in execute_task() 235 queue.initialize_team_queues(num_worker_threads); in execute_task() 237 latch num_tasks_remaining(num_worker_threads); in execute_task() 238 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() [all …]
|
H A D | Kokkos_HPX_WorkGraphPolicy.hpp | 86 const int num_worker_threads = Kokkos::Experimental::HPX::concurrency(); in execute_task() local 91 latch num_tasks_remaining(num_worker_threads); in execute_task() 92 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() 94 for (int thread = 0; thread < num_worker_threads; ++thread) { in execute_task()
|
/dports/devel/kokkos/kokkos-3.4.01/core/src/HPX/ |
H A D | Kokkos_HPX_Task.hpp | 97 buffer.resize(num_worker_threads, 512); in execute_task() 101 latch num_tasks_remaining(num_worker_threads); in execute_task() 102 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() 104 for (int thread = 0; thread < num_worker_threads; ++thread) { in execute_task() 106 num_worker_threads]() { in execute_task() 115 Kokkos::Experimental::HPX(), num_worker_threads, 1), in execute_task() 232 buffer.resize(num_worker_threads, 512); in execute_task() 235 queue.initialize_team_queues(num_worker_threads); in execute_task() 237 latch num_tasks_remaining(num_worker_threads); in execute_task() 238 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() [all …]
|
H A D | Kokkos_HPX_WorkGraphPolicy.hpp | 86 const int num_worker_threads = Kokkos::Experimental::HPX::concurrency(); in execute_task() local 91 latch num_tasks_remaining(num_worker_threads); in execute_task() 92 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() 94 for (int thread = 0; thread < num_worker_threads; ++thread) { in execute_task()
|
/dports/science/sparta/sparta-20Oct2021/lib/kokkos/core/src/HPX/ |
H A D | Kokkos_HPX_Task.hpp | 97 buffer.resize(num_worker_threads, 512); in execute_task() 101 latch num_tasks_remaining(num_worker_threads); in execute_task() 102 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() 104 for (int thread = 0; thread < num_worker_threads; ++thread) { in execute_task() 106 num_worker_threads]() { in execute_task() 115 Kokkos::Experimental::HPX(), num_worker_threads, 1), in execute_task() 232 buffer.resize(num_worker_threads, 512); in execute_task() 235 queue.initialize_team_queues(num_worker_threads); in execute_task() 237 latch num_tasks_remaining(num_worker_threads); in execute_task() 238 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() [all …]
|
H A D | Kokkos_HPX_WorkGraphPolicy.hpp | 86 const int num_worker_threads = Kokkos::Experimental::HPX::concurrency(); in execute_task() local 91 latch num_tasks_remaining(num_worker_threads); in execute_task() 92 ChunkedRoundRobinExecutor exec(num_worker_threads); in execute_task() 94 for (int thread = 0; thread < num_worker_threads; ++thread) { in execute_task()
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/jpeg-xl/lib/threads/ |
H A D | thread_parallel_runner_internal.cc | 108 const uint32_t num_worker_threads = self->num_worker_threads_; in RunRange() local 120 const uint32_t my_size = std::max(num_tasks / (num_worker_threads * 4), 1); in RunRange() 127 std::max(num_remaining / (num_worker_threads * 4), 1u); in RunRange() 173 ThreadParallelRunner::ThreadParallelRunner(const int num_worker_threads) in ThreadParallelRunner() argument 177 (void)num_worker_threads; in ThreadParallelRunner() 179 : num_worker_threads_(num_worker_threads), in ThreadParallelRunner() 180 num_threads_(std::max(num_worker_threads, 1)) { in ThreadParallelRunner()
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/jpeg-xl/lib/threads/ |
H A D | thread_parallel_runner_internal.cc | 108 const uint32_t num_worker_threads = self->num_worker_threads_; in RunRange() local 120 const uint32_t my_size = std::max(num_tasks / (num_worker_threads * 4), 1); in RunRange() 127 std::max(num_remaining / (num_worker_threads * 4), 1u); in RunRange() 173 ThreadParallelRunner::ThreadParallelRunner(const int num_worker_threads) in ThreadParallelRunner() argument 177 (void)num_worker_threads; in ThreadParallelRunner() 179 : num_worker_threads_(num_worker_threads), in ThreadParallelRunner() 180 num_threads_(std::max(num_worker_threads, 1)) { in ThreadParallelRunner()
|
/dports/www/firefox/firefox-99.0/third_party/jpeg-xl/lib/threads/ |
H A D | thread_parallel_runner_internal.cc | 108 const uint32_t num_worker_threads = self->num_worker_threads_; in RunRange() local 120 const uint32_t my_size = std::max(num_tasks / (num_worker_threads * 4), 1); in RunRange() 129 std::max(num_remaining / (num_worker_threads * 4), 1u); in RunRange() 175 ThreadParallelRunner::ThreadParallelRunner(const int num_worker_threads) in ThreadParallelRunner() argument 179 (void)num_worker_threads; in ThreadParallelRunner() 181 : num_worker_threads_(num_worker_threads), in ThreadParallelRunner() 182 num_threads_(std::max(num_worker_threads, 1)) { in ThreadParallelRunner()
|
/dports/graphics/libjxl/libjxl-0.6.1/lib/threads/ |
H A D | thread_parallel_runner_internal.cc | 108 const uint32_t num_worker_threads = self->num_worker_threads_; in RunRange() local 120 const uint32_t my_size = std::max(num_tasks / (num_worker_threads * 4), 1); in RunRange() 129 std::max(num_remaining / (num_worker_threads * 4), 1u); in RunRange() 175 ThreadParallelRunner::ThreadParallelRunner(const int num_worker_threads) in ThreadParallelRunner() argument 179 (void)num_worker_threads; in ThreadParallelRunner() 181 : num_worker_threads_(num_worker_threads), in ThreadParallelRunner() 182 num_threads_(std::max(num_worker_threads, 1)) { in ThreadParallelRunner()
|
/dports/emulators/dolphin-emu/dolphin-3152428/Source/Core/VideoCommon/ |
H A D | AsyncShaderCompiler.cpp | 115 bool AsyncShaderCompiler::StartWorkerThreads(u32 num_worker_threads) in StartWorkerThreads() argument 117 if (num_worker_threads == 0) in StartWorkerThreads() 120 for (u32 i = 0; i < num_worker_threads; i++) in StartWorkerThreads() 147 bool AsyncShaderCompiler::ResizeWorkerThreads(u32 num_worker_threads) in ResizeWorkerThreads() argument 149 if (m_worker_threads.size() == num_worker_threads) in ResizeWorkerThreads() 153 return StartWorkerThreads(num_worker_threads); in ResizeWorkerThreads()
|
/dports/science/lammps/lammps-stable_29Sep2021/lib/kokkos/core/src/ |
H A D | Kokkos_HPX.hpp | 1384 buffer.resize(num_worker_threads, value_size); in execute_task() 1427 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1440 buffer.resize(num_worker_threads, value_size); in execute_task() 1475 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1574 buffer.resize(num_worker_threads, value_size); in execute_task() 1677 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1799 barrier bar(num_worker_threads); in execute_task() 1800 latch num_tasks_remaining(num_worker_threads); in execute_task() 1919 barrier bar(num_worker_threads); in execute_task() 1963 if (t == num_worker_threads - 1) { in execute_task() [all …]
|
/dports/devel/kokkos/kokkos-3.4.01/core/src/ |
H A D | Kokkos_HPX.hpp | 1384 buffer.resize(num_worker_threads, value_size); in execute_task() 1427 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1440 buffer.resize(num_worker_threads, value_size); in execute_task() 1475 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1574 buffer.resize(num_worker_threads, value_size); in execute_task() 1677 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1799 barrier bar(num_worker_threads); in execute_task() 1800 latch num_tasks_remaining(num_worker_threads); in execute_task() 1919 barrier bar(num_worker_threads); in execute_task() 1963 if (t == num_worker_threads - 1) { in execute_task() [all …]
|
/dports/science/sparta/sparta-20Oct2021/lib/kokkos/core/src/ |
H A D | Kokkos_HPX.hpp | 1384 buffer.resize(num_worker_threads, value_size); in execute_task() 1427 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1440 buffer.resize(num_worker_threads, value_size); in execute_task() 1475 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1574 buffer.resize(num_worker_threads, value_size); in execute_task() 1677 for (int i = 1; i < num_worker_threads; ++i) { in execute_task() 1799 barrier bar(num_worker_threads); in execute_task() 1800 latch num_tasks_remaining(num_worker_threads); in execute_task() 1919 barrier bar(num_worker_threads); in execute_task() 1963 if (t == num_worker_threads - 1) { in execute_task() [all …]
|
/dports/security/softether-devel/v4.36-9754/src/BuildUtil/CoreUtil/ |
H A D | Thread.cs | 130 int num_worker_threads; field in CoreUtil.WorkerQueuePrivate 165 public WorkerQueuePrivate(ThreadProc thread_proc, int num_worker_threads, object[] tasks) in WorkerQueuePrivate() argument 171 this.num_worker_threads = num_worker_threads; in WorkerQueuePrivate() 180 for (i = 0; i < num_worker_threads; i++) in WorkerQueuePrivate() 552 …public static void ProcessWorkQueue(ThreadProc thread_proc, int num_worker_threads, object[] tasks) in ProcessWorkQueue() argument 554 WorkerQueuePrivate q = new WorkerQueuePrivate(thread_proc, num_worker_threads, tasks); in ProcessWorkQueue()
|
/dports/security/softether/v4.38-9760/src/BuildUtil/CoreUtil/ |
H A D | Thread.cs | 130 int num_worker_threads; field in CoreUtil.WorkerQueuePrivate 165 public WorkerQueuePrivate(ThreadProc thread_proc, int num_worker_threads, object[] tasks) in WorkerQueuePrivate() argument 171 this.num_worker_threads = num_worker_threads; in WorkerQueuePrivate() 180 for (i = 0; i < num_worker_threads; i++) in WorkerQueuePrivate() 552 …public static void ProcessWorkQueue(ThreadProc thread_proc, int num_worker_threads, object[] tasks) in ProcessWorkQueue() argument 554 WorkerQueuePrivate q = new WorkerQueuePrivate(thread_proc, num_worker_threads, tasks); in ProcessWorkQueue()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/v8/src/libplatform/ |
H A D | default-platform.cc | 50 std::unique_ptr<JobTask> job_task, size_t num_worker_threads) { in NewDefaultJobHandle() argument 52 platform, std::move(job_task), priority, num_worker_threads)); in NewDefaultJobHandle() 216 size_t num_worker_threads = NumberOfWorkerThreads(); in PostJob() local 217 if (priority == TaskPriority::kBestEffort && num_worker_threads > 2) { in PostJob() 218 num_worker_threads = 2; in PostJob() 221 num_worker_threads); in PostJob()
|
/dports/lang/v8/v8-9.6.180.12/src/libplatform/ |
H A D | default-platform.cc | 73 std::unique_ptr<JobTask> job_task, size_t num_worker_threads) { in NewDefaultJobHandle() argument 75 platform, std::move(job_task), priority, num_worker_threads)); in NewDefaultJobHandle() 239 size_t num_worker_threads = NumberOfWorkerThreads(); in PostJob() local 240 if (priority == TaskPriority::kBestEffort && num_worker_threads > 2) { in PostJob() 241 num_worker_threads = 2; in PostJob() 244 num_worker_threads); in PostJob()
|
/dports/graphics/kf5-kimageformats/kimageformats-5.89.0/src/imageformats/ |
H A D | jxl.cpp | 124 int num_worker_threads = QThread::idealThreadCount(); in ensureDecoder() local 125 if (!m_runner && num_worker_threads >= 4) { in ensureDecoder() 128 num_worker_threads = num_worker_threads / 2; in ensureDecoder() 129 num_worker_threads = qBound(2, num_worker_threads, 64); in ensureDecoder() 130 m_runner = JxlThreadParallelRunnerCreate(nullptr, num_worker_threads); in ensureDecoder() 426 int num_worker_threads = qBound(1, QThread::idealThreadCount(), 64); in write() local 428 if (num_worker_threads > 1) { in write() 429 runner = JxlThreadParallelRunnerCreate(nullptr, num_worker_threads); in write()
|
/dports/graphics/libjxl/libjxl-0.6.1/lib/include/jxl/ |
H A D | thread_parallel_runner_cxx.h | 54 const JxlMemoryManager* memory_manager, size_t num_worker_threads) { in JxlThreadParallelRunnerMake() argument 56 JxlThreadParallelRunnerCreate(memory_manager, num_worker_threads)); in JxlThreadParallelRunnerMake()
|
/dports/www/firefox/firefox-99.0/third_party/jpeg-xl/lib/include/jxl/ |
H A D | thread_parallel_runner_cxx.h | 57 const JxlMemoryManager* memory_manager, size_t num_worker_threads) { in JxlThreadParallelRunnerMake() argument 59 JxlThreadParallelRunnerCreate(memory_manager, num_worker_threads)); in JxlThreadParallelRunnerMake()
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/jpeg-xl/lib/include/jxl/ |
H A D | thread_parallel_runner_cxx.h | 54 const JxlMemoryManager* memory_manager, size_t num_worker_threads) { in JxlThreadParallelRunnerMake() argument 56 JxlThreadParallelRunnerCreate(memory_manager, num_worker_threads)); in JxlThreadParallelRunnerMake()
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/jpeg-xl/lib/include/jxl/ |
H A D | thread_parallel_runner_cxx.h | 54 const JxlMemoryManager* memory_manager, size_t num_worker_threads) { in JxlThreadParallelRunnerMake() argument 56 JxlThreadParallelRunnerCreate(memory_manager, num_worker_threads)); in JxlThreadParallelRunnerMake()
|
/dports/graphics/libjxl/libjxl-0.6.1/lib/jxl/base/ |
H A D | thread_pool_internal.h | 30 int num_worker_threads = std::thread::hardware_concurrency()) 33 runner_(num_worker_threads) {}
|
/dports/www/firefox/firefox-99.0/third_party/jpeg-xl/lib/jxl/base/ |
H A D | thread_pool_internal.h | 30 int num_worker_threads = std::thread::hardware_concurrency()) 33 runner_(num_worker_threads) {}
|