onert::exec::ThreadPool Class Reference

#include <ThreadPool.h>

Public Member Functions
	ThreadPool (uint32_t num_threads=1)
	Coustruct ThreadPool object.
	~ThreadPool ()
	Destroy ThreadPool object.
void	enqueue (std::unique_ptr< IFunction > &&fn)
	Enqueue a function.
uint32_t	numJobsInQueue ()
	Get number of jobs in worker's queue.
void	finish ()
	Block until all jobs are finished.

Detailed Description

Definition at line 29 of file ThreadPool.h.

Constructor & Destructor Documentation

ThreadPool()

onert::exec::ThreadPool::ThreadPool

(

uint32_t

num_threads = 1

)

Coustruct ThreadPool object.

Parameters

num_threads

Number of threads

Definition at line 24 of file ThreadPool.cc.

{
  assert(num_threads >= 1);
 
  for (uint32_t i = 0; i < num_threads; i++)
  {
    _threads.emplace_back(std::ref(_worker));
  }
}

~ThreadPool()

onert::exec::ThreadPool::~ThreadPool

(

)

Destroy ThreadPool object.

Definition at line 34 of file ThreadPool.cc.

{
  if (!_threads.empty())
  {
    _worker.terminate();
    join();
  }
}

References onert::exec::WorkQueue::terminate().

Member Function Documentation

enqueue()

void onert::exec::ThreadPool::enqueue

(

std::unique_ptr< IFunction > &&

fn

)

Enqueue a function.

Parameters

fn	A function to be queued

Definition at line 43 of file ThreadPool.cc.

{ _worker.enqueue(std::move(fn)); }

References onert::exec::WorkQueue::enqueue().

finish()

void onert::exec::ThreadPool::finish

(

)

Block until all jobs are finished.

Definition at line 56 of file ThreadPool.cc.

{
  _worker.finish();
  join();
}

References onert::exec::WorkQueue::finish().

numJobsInQueue()

uint32_t onert::exec::ThreadPool::numJobsInQueue

(

)

Get number of jobs in worker's queue.

Returns

Number of jobs

Definition at line 45 of file ThreadPool.cc.

{ return _worker.numJobsInQueue(); }

References onert::exec::WorkQueue::numJobsInQueue().

---

The documentation for this class was generated from the following files:

• runtime/onert/core/src/exec/ThreadPool.h
• runtime/onert/core/src/exec/ThreadPool.cc