Abstract implementation of TaskQueue that wraps turi::thread_pool. More...

#include <ml/neural_net/PosixTaskQueue.hpp>

Public Member Functions
void	DispatchAsync (std::function< void()> task) override

void	DispatchSync (std::function< void()> task) override

virtual void	DispatchApply (size_t n, std::function< void(size_t i)> task)=0

Detailed Description

Abstract implementation of TaskQueue that wraps turi::thread_pool.

Definition at line 17 of file PosixTaskQueue.hpp.

Member Function Documentation

◆ DispatchApply()

virtual void turi::neural_net::TaskQueue::DispatchApply	(	size_t	n,
		std::function< void(size_t i)>	task
	)

pure virtualinherited

Submits a function to this task queue n times, with arguments ranging from 0 to n - 1. When dispatched to a concurrent queue, the function must be reentrant. Rethrows the first exception thrown by any task invocation.

Implemented in turi::neural_net::GlobalPosixTaskQueue, turi::neural_net::SerialPosixTaskQueue, and turi::neural_net::GrandCentralDispatchQueue.

◆ DispatchAsync()

void turi::neural_net::PosixTaskQueue::DispatchAsync ( std::function< void()> task )

overridevirtual

Submits a function to this task queue without waiting for the function to finish. The task must not throw an exception.

Implements turi::neural_net::TaskQueue.

◆ DispatchSync()

void turi::neural_net::PosixTaskQueue::DispatchSync ( std::function< void()> task )