decaf::internal::util::concurrent::TransferQueue< E > Class Template Reference

This extends Scherer-Scott dual queue algorithm, differing, among other ways, by using modes within nodes rather than marked pointers. More...

#include <src/main/decaf/internal/util/concurrent/TransferQueue.h>

Inheritance diagram for decaf::internal::util::concurrent::TransferQueue< E >:

Public Member Functions
	TransferQueue ()
virtual	~TransferQueue ()
virtual void	transfer (E *e, bool timed, long long nanos)
	Performs a put.
virtual E *	transfer (bool timed, long long nanos)
	Performs a take.

Detailed Description

template<typename E>
class decaf::internal::util::concurrent::TransferQueue< E >

This extends Scherer-Scott dual queue algorithm, differing, among other ways, by using modes within nodes rather than marked pointers.

The algorithm is a little simpler than that for stacks because fulfillers do not need explicit nodes, and matching is done by CAS'ing QNode.item field from non-null to null (for put) or vice versa (for take).

Constructor & Destructor Documentation

TransferQueue()

template<typename E>

decaf::internal::util::concurrent::TransferQueue< E >::TransferQueue ( )

inline

~TransferQueue()

template<typename E>

virtual decaf::internal::util::concurrent::TransferQueue< E >::~TransferQueue ( )

inlinevirtual

Member Function Documentation

transfer() [1/2]

template<typename E>

virtual E * decaf::internal::util::concurrent::TransferQueue< E >::transfer ( bool timed, long long nanos )

inlinevirtual

Performs a take.

Parameters

timed	if this operation should timeout
nanos	the timeout, in nanoseconds

Returns

the item provided or received;

Exceptions

TimeoutException	if the operation timed out waiting for the producer to offer an item.
InterruptedException	if the thread was interrupted while waiting for the producer to offer an item.

Implements decaf::internal::util::concurrent::Transferer< E >.

References NULL.

transfer() [2/2]

template<typename E>

virtual void decaf::internal::util::concurrent::TransferQueue< E >::transfer ( E * e, bool timed, long long nanos )

inlinevirtual

Performs a put.

Parameters

e	the item to be handed to a consumer;
timed	if this operation should timeout
nanos	the timeout, in nanoseconds

Exceptions

TimeoutException	if the operation timed out waiting for the consumer to accept the item offered.
InterruptedException	if the thread was interrupted while waiting for the consumer to accept the item offered.

Implements decaf::internal::util::concurrent::Transferer< E >.

---

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

• src/main/decaf/internal/util/concurrent/TransferQueue.h