Home
last modified time | relevance | path

Searched refs:num_worker_threads (Results 1 – 25 of 125) sorted by relevance

12345

/dports/science/lammps/lammps-stable_29Sep2021/lib/kokkos/core/src/HPX/
H A DKokkos_HPX_Task.hpp97 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 DKokkos_HPX_WorkGraphPolicy.hpp86 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 DKokkos_HPX_Task.hpp97 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 DKokkos_HPX_WorkGraphPolicy.hpp86 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 DKokkos_HPX_Task.hpp97 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 DKokkos_HPX_WorkGraphPolicy.hpp86 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 Dthread_parallel_runner_internal.cc108 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 Dthread_parallel_runner_internal.cc108 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 Dthread_parallel_runner_internal.cc108 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 Dthread_parallel_runner_internal.cc108 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 DAsyncShaderCompiler.cpp115 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 DKokkos_HPX.hpp1384 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 DKokkos_HPX.hpp1384 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 DKokkos_HPX.hpp1384 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 DThread.cs130 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 DThread.cs130 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 Ddefault-platform.cc50 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 Ddefault-platform.cc73 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 Djxl.cpp124 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 Dthread_parallel_runner_cxx.h54 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 Dthread_parallel_runner_cxx.h57 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 Dthread_parallel_runner_cxx.h54 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 Dthread_parallel_runner_cxx.h54 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 Dthread_pool_internal.h30 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 Dthread_pool_internal.h30 int num_worker_threads = std::thread::hardware_concurrency())
33 runner_(num_worker_threads) {}

12345