#include <tasks.h>

Inheritance diagram for Realm::ThreadedTaskScheduler:

Collaboration diagram for Realm::ThreadedTaskScheduler:

Classes
class	WorkCounter

class	WorkCounterUpdater

Public Member Functions
	ThreadedTaskScheduler (void)

virtual	~ThreadedTaskScheduler (void)

virtual void	add_task_queue (TaskQueue *queue)

virtual void	remove_task_queue (TaskQueue *queue)

virtual void	configure_bgworker (BackgroundWorkManager *manager, long long max_timeslice, int numa_domain)

void	add_task_context (const TaskContextManager *_manager)

virtual void	start (void)=0

virtual void	shutdown (void)=0

virtual void	thread_blocking (Thread *thread)

virtual void	thread_ready (Thread *thread)

virtual void	set_thread_priority (Thread *thread, int new_priority)

void	add_internal_task (InternalTask *itask)

void	scheduler_loop (void)

void	scheduler_loop_wlock (void)

Public Member Functions inherited from Realm::ThreadScheduler
virtual	~ThreadScheduler (void)

virtual void	thread_starting (Thread *thread)=0

virtual void	thread_terminating (Thread *thread)=0

Public Attributes
bool	cfg_reuse_workers

int	cfg_max_idle_workers

int	cfg_min_active_workers

int	cfg_max_active_workers

Protected Types
typedef PriorityQueue< Thread *, DummyLock >	ResumableQueue

Protected Member Functions
virtual bool	execute_task (Task *task)=0

virtual void	execute_internal_task (InternalTask *task)=0

virtual Thread *	worker_create (bool make_active)=0

virtual void	worker_sleep (Thread *switch_to)=0

virtual void	worker_wake (Thread *to_wake)=0

virtual void	worker_terminate (Thread *switch_to)=0

Task *	get_best_ready_task (int &task_priority)

void	update_worker_count (int active_delta, int unassigned_delta, bool check=true)

virtual void	wait_for_work (uint64_t old_work_counter)

Protected Member Functions inherited from Realm::ThreadScheduler
Thread::State	update_thread_state (Thread *thread, Thread::State new_state)

bool	try_update_thread_state (Thread *thread, Thread::State old_state, Thread::State new_state)

Protected Attributes
FIFOMutex	lock

std::vector< TaskQueue * >	task_queues

std::vector< Thread * >	idle_workers

std::set< Thread * >	blocked_workers

std::set< Thread * >	spinning_workers

std::vector< const TaskContextManager * >	context_managers

InternalTask::TaskList	internal_tasks

ResumableQueue	resumable_workers

std::map< Thread *, int >	worker_priorities

atomic< bool >	shutdown_flag

int	active_worker_count

int	unassigned_worker_count

WorkCounter	work_counter

WorkCounterUpdater< TaskQueue >	wcu_task_queues

WorkCounterUpdater< ResumableQueue >	wcu_resume_queue

BackgroundWorkManager::Worker	bgworker

atomic< bool >	bgworker_interrupt

long long	max_bgwork_timeslice

Member Typedef Documentation

◆ ResumableQueue

typedef PriorityQueue<Thread *, DummyLock> Realm::ThreadedTaskScheduler::ResumableQueue

protected

Constructor & Destructor Documentation

◆ ThreadedTaskScheduler()

Realm::ThreadedTaskScheduler::ThreadedTaskScheduler ( void )

◆ ~ThreadedTaskScheduler()

virtual Realm::ThreadedTaskScheduler::~ThreadedTaskScheduler ( void )

virtual

Member Function Documentation

◆ add_internal_task()

void Realm::ThreadedTaskScheduler::add_internal_task ( InternalTask * itask )

◆ add_task_context()

void Realm::ThreadedTaskScheduler::add_task_context ( const TaskContextManager * _manager )

◆ add_task_queue()

virtual void Realm::ThreadedTaskScheduler::add_task_queue ( TaskQueue * queue )

virtual

Reimplemented in Realm::KernelThreadTaskScheduler.

◆ configure_bgworker()

virtual void Realm::ThreadedTaskScheduler::configure_bgworker	(	BackgroundWorkManager *	manager,
		long long	max_timeslice,
		int	numa_domain
	)

virtual

◆ execute_internal_task()

virtual void Realm::ThreadedTaskScheduler::execute_internal_task ( InternalTask * task )

protectedpure virtual

Implemented in Realm::PythonThreadTaskScheduler, and Realm::KernelThreadTaskScheduler.

◆ execute_task()

virtual bool Realm::ThreadedTaskScheduler::execute_task ( Task * task )

protectedpure virtual

Implemented in Realm::PythonThreadTaskScheduler, and Realm::KernelThreadTaskScheduler.

◆ get_best_ready_task()

Task * Realm::ThreadedTaskScheduler::get_best_ready_task ( int & task_priority )

protected

◆ remove_task_queue()

virtual void Realm::ThreadedTaskScheduler::remove_task_queue ( TaskQueue * queue )

virtual

Reimplemented in Realm::KernelThreadTaskScheduler.

◆ scheduler_loop()

void Realm::ThreadedTaskScheduler::scheduler_loop ( void )

◆ scheduler_loop_wlock()

void Realm::ThreadedTaskScheduler::scheduler_loop_wlock ( void )

◆ set_thread_priority()

virtual void Realm::ThreadedTaskScheduler::set_thread_priority	(	Thread *	thread,
		int	new_priority
	)

virtual

Implements Realm::ThreadScheduler.

◆ shutdown()

virtual void Realm::ThreadedTaskScheduler::shutdown ( void )

pure virtual

Implemented in Realm::KernelThreadTaskScheduler.

◆ start()

virtual void Realm::ThreadedTaskScheduler::start ( void )

pure virtual

Implemented in Realm::KernelThreadTaskScheduler.

◆ thread_blocking()

virtual void Realm::ThreadedTaskScheduler::thread_blocking ( Thread * thread )

virtual

Implements Realm::ThreadScheduler.

Reimplemented in Realm::PythonThreadTaskScheduler.

◆ thread_ready()

virtual void Realm::ThreadedTaskScheduler::thread_ready ( Thread * thread )

virtual

Implements Realm::ThreadScheduler.

Reimplemented in Realm::PythonThreadTaskScheduler.

◆ update_worker_count()

void Realm::ThreadedTaskScheduler::update_worker_count	(	int	active_delta,
		int	unassigned_delta,
		bool	check = `true`
	)

protected

◆ wait_for_work()

virtual void Realm::ThreadedTaskScheduler::wait_for_work ( uint64_t old_work_counter )

protectedvirtual

Reimplemented in Realm::KernelThreadTaskScheduler.

◆ worker_create()

virtual Thread * Realm::ThreadedTaskScheduler::worker_create ( bool make_active )

protectedpure virtual

Implemented in Realm::PythonThreadTaskScheduler, and Realm::KernelThreadTaskScheduler.

◆ worker_sleep()

virtual void Realm::ThreadedTaskScheduler::worker_sleep ( Thread * switch_to )

protectedpure virtual

Implemented in Realm::KernelThreadTaskScheduler.

◆ worker_terminate()

virtual void Realm::ThreadedTaskScheduler::worker_terminate ( Thread * switch_to )

protectedpure virtual

Implemented in Realm::PythonThreadTaskScheduler, and Realm::KernelThreadTaskScheduler.

◆ worker_wake()

virtual void Realm::ThreadedTaskScheduler::worker_wake ( Thread * to_wake )

protectedpure virtual

Implemented in Realm::KernelThreadTaskScheduler.

Member Data Documentation

◆ active_worker_count

int Realm::ThreadedTaskScheduler::active_worker_count

protected

◆ bgworker

BackgroundWorkManager::Worker Realm::ThreadedTaskScheduler::bgworker

protected

◆ bgworker_interrupt

atomic<bool> Realm::ThreadedTaskScheduler::bgworker_interrupt

protected

◆ blocked_workers

std::set<Thread *> Realm::ThreadedTaskScheduler::blocked_workers

protected

◆ cfg_max_active_workers

int Realm::ThreadedTaskScheduler::cfg_max_active_workers

◆ cfg_max_idle_workers

int Realm::ThreadedTaskScheduler::cfg_max_idle_workers

◆ cfg_min_active_workers

int Realm::ThreadedTaskScheduler::cfg_min_active_workers

◆ cfg_reuse_workers

bool Realm::ThreadedTaskScheduler::cfg_reuse_workers

◆ context_managers

std::vector<const TaskContextManager *> Realm::ThreadedTaskScheduler::context_managers

protected

◆ idle_workers

std::vector<Thread *> Realm::ThreadedTaskScheduler::idle_workers

protected

◆ internal_tasks

InternalTask::TaskList Realm::ThreadedTaskScheduler::internal_tasks

protected

◆ lock

FIFOMutex Realm::ThreadedTaskScheduler::lock

protected

◆ max_bgwork_timeslice

long long Realm::ThreadedTaskScheduler::max_bgwork_timeslice

protected

◆ resumable_workers

ResumableQueue Realm::ThreadedTaskScheduler::resumable_workers

protected

◆ shutdown_flag

atomic<bool> Realm::ThreadedTaskScheduler::shutdown_flag

protected

◆ spinning_workers

std::set<Thread *> Realm::ThreadedTaskScheduler::spinning_workers

protected

◆ task_queues

std::vector<TaskQueue *> Realm::ThreadedTaskScheduler::task_queues

protected

◆ unassigned_worker_count

int Realm::ThreadedTaskScheduler::unassigned_worker_count

protected

◆ wcu_resume_queue

WorkCounterUpdater<ResumableQueue> Realm::ThreadedTaskScheduler::wcu_resume_queue

protected

◆ wcu_task_queues

WorkCounterUpdater<TaskQueue> Realm::ThreadedTaskScheduler::wcu_task_queues

protected

◆ work_counter

WorkCounter Realm::ThreadedTaskScheduler::work_counter

protected

◆ worker_priorities

std::map<Thread *, int> Realm::ThreadedTaskScheduler::worker_priorities

protected

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

/home/runner/work/realm/realm/realm-src/src/realm/tasks.h

Classes

Public Member Functions

Public Attributes

Protected Types

Protected Member Functions

Protected Attributes

Member Typedef Documentation

◆ ResumableQueue

Constructor & Destructor Documentation

◆ ThreadedTaskScheduler()

◆ ~ThreadedTaskScheduler()

Member Function Documentation

◆ add_internal_task()

◆ add_task_context()

◆ add_task_queue()

◆ configure_bgworker()

◆ execute_internal_task()

◆ execute_task()

◆ get_best_ready_task()

◆ remove_task_queue()

◆ scheduler_loop()

◆ scheduler_loop_wlock()

◆ set_thread_priority()

◆ shutdown()

◆ start()

◆ thread_blocking()

◆ thread_ready()

◆ update_worker_count()

◆ wait_for_work()

◆ worker_create()

◆ worker_sleep()

◆ worker_terminate()

◆ worker_wake()

Member Data Documentation

◆ active_worker_count

◆ bgworker

◆ bgworker_interrupt

◆ blocked_workers

◆ cfg_max_active_workers

◆ cfg_max_idle_workers

◆ cfg_min_active_workers

◆ cfg_reuse_workers

◆ context_managers

◆ idle_workers

◆ internal_tasks

◆ lock

◆ max_bgwork_timeslice

◆ resumable_workers

◆ shutdown_flag

◆ spinning_workers

◆ task_queues

◆ unassigned_worker_count

◆ wcu_resume_queue

◆ wcu_task_queues

◆ work_counter

◆ worker_priorities