#include <xmipp_threads.h>

Inheritance diagram for ThreadTaskDistributor:

Collaboration diagram for ThreadTaskDistributor:

Public Member Functions
	ThreadTaskDistributor (size_t nTasks, size_t bSize)

virtual	~ThreadTaskDistributor ()

virtual void	reset ()

Public Member Functions inherited from ParallelTaskDistributor
	ParallelTaskDistributor (size_t nTasks, size_t bSize)

virtual	~ParallelTaskDistributor ()

void	clear ()

void	setBlockSize (size_t bSize)

int	getBlockSize () const

bool	getTasks (size_t &first, size_t &last)

bool	setAssignedTasks (size_t tasks)

Protected Member Functions
virtual void	lock ()

virtual void	unlock ()

virtual bool	distribute (size_t &first, size_t &last)

Protected Attributes
Mutex	mutex
	Mutex to synchronize access to critical region. More...

Protected Attributes inherited from ParallelTaskDistributor
size_t	blockSize

size_t	assignedTasks

Additional Inherited Members
Public Attributes inherited from ParallelTaskDistributor
size_t	numberOfTasks

Detailed Description

This class is a concrete implementation of ParallelTaskDistributor for POSIX threads. It use mutex as the locking mechanism and distributes tasks from 0 to numberOfTasks.

Definition at line 451 of file xmipp_threads.h.

Constructor & Destructor Documentation

◆ ThreadTaskDistributor()

ThreadTaskDistributor::ThreadTaskDistributor	(	size_t	nTasks,
		size_t	bSize
	)

inline

Definition at line 454 of file xmipp_threads.h.

454 :ParallelTaskDistributor(nTasks, bSize)

455 {}

ParallelTaskDistributor::ParallelTaskDistributor

ParallelTaskDistributor(size_t nTasks, size_t bSize)

Definition: xmipp_threads.cpp:289

◆ ~ThreadTaskDistributor()

virtual ThreadTaskDistributor::~ThreadTaskDistributor ( )

inlinevirtual

Definition at line 456 of file xmipp_threads.h.

457 {}

Member Function Documentation

◆ distribute()

bool ThreadTaskDistributor::distribute	(	size_t &	first,
		size_t &	last
	)

protectedvirtual

Implements ParallelTaskDistributor.

Reimplemented in MpiTaskDistributor.

Definition at line 346 of file xmipp_threads.cpp.

 {
     bool result = true;
     first = last = 0;
     if (assignedTasks >= numberOfTasks)
     {
         result = false;
     }
     else
     {
         first = assignedTasks;
         assignedTasks
         = (assignedTasks + blockSize < numberOfTasks) ? (assignedTasks
                 + blockSize) : numberOfTasks;
         last = assignedTasks - 1;
     }
     return result;
 }