Arcane  4.1.12.0
User documentation
Loading...
Searching...
No Matches
RunQueuePool.cc
1// -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
2//-----------------------------------------------------------------------------
3// Copyright 2000-2026 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
4// See the top-level COPYRIGHT file for details.
5// SPDX-License-Identifier: Apache-2.0
6//-----------------------------------------------------------------------------
7/*---------------------------------------------------------------------------*/
8/* RunQueuePool.cc (C) 2000-2025 */
9/* */
10/* Collection of RunQueues. */
11/*---------------------------------------------------------------------------*/
12/*---------------------------------------------------------------------------*/
13
14#include "arccore/common/accelerator/RunQueuePool.h"
15#include "arccore/common/accelerator/RunQueueBuildInfo.h"
16
17/*---------------------------------------------------------------------------*/
18/*---------------------------------------------------------------------------*/
19
20namespace Arcane::Accelerator
21{
22
23/*---------------------------------------------------------------------------*/
24/*---------------------------------------------------------------------------*/
25
26RunQueuePool::
27RunQueuePool()
28: m_pool_size(1)
29{
30 m_pool.add(RunQueue{});
31}
32
33/*---------------------------------------------------------------------------*/
34/*---------------------------------------------------------------------------*/
35
36/*---------------------------------------------------------------------------*/
37/*---------------------------------------------------------------------------*/
38
39void RunQueuePool::
40initialize(Runner& runner, Int32 pool_size)
41{
42 initialize(runner, pool_size, {});
43}
44
45/*---------------------------------------------------------------------------*/
46/*---------------------------------------------------------------------------*/
47
48void RunQueuePool::
49initialize(Runner& runner, Int32 pool_size, const RunQueueBuildInfo& bi)
50{
51 if (pool_size <= 0)
52 pool_size = 1;
53 m_pool_size = pool_size;
54
55 m_pool.clear();
56 m_pool.reserve(m_pool_size);
57
58 for (Int32 i = 0; i < pool_size; ++i) {
59 m_pool.add(makeQueue(runner, bi));
60 }
61}
62
63/*---------------------------------------------------------------------------*/
64/*---------------------------------------------------------------------------*/
65
66void RunQueuePool::
67barrier() const
68{
69 for (auto q : m_pool)
70 q.barrier();
71}
72
73/*---------------------------------------------------------------------------*/
74/*---------------------------------------------------------------------------*/
75
76void RunQueuePool::
77setAsync(bool v) const
78{
79 for (auto q : m_pool)
80 q.setAsync(v);
81}
82
83/*---------------------------------------------------------------------------*/
84/*---------------------------------------------------------------------------*/
85
86} // End namespace Arcane::Accelerator
87
88/*---------------------------------------------------------------------------*/
89/*---------------------------------------------------------------------------*/
Arcane::Accelerator::RunQueuePool::RunQueuePool
RunQueuePool()
Creates an empty instance.
Definition RunQueuePool.cc:27
Arcane::Accelerator::RunQueuePool::setAsync
void setAsync(bool v) const
Modifies the asynchronous state of the queues.
Definition RunQueuePool.cc:77
Arcane::Accelerator::RunQueuePool::barrier
void barrier() const
Forces waiting for all RunQueues.
Definition RunQueuePool.cc:67
Arcane::Accelerator::RunQueuePool::initialize
void initialize(Runner &runner, Int32 pool_size)
Initializes the instance with pool_size RunQueues.
Definition RunQueuePool.cc:40
Arcane::Accelerator
Namespace for accelerator usage.
Definition ArcaneTypes.h:652
Arcane::Accelerator::makeQueue
RunQueue makeQueue(const Runner &runner)
Creates a queue associated with runner.
Definition arccore/src/common/arccore/common/accelerator/Runner.h:219
Arcane::Int32
std::int32_t Int32
Signed integer type of 32 bits.
Definition ArccoreGlobal.h:233