Performs single read operation using Read<(Of <(T>)>)(T, ITransaction, Int64, ReadModifiers)
under an exclusive read lock. This receive operation handler allows to lock entries so other
receive operations won't be able to obtain it (mimics the take operation) but without actually
performing a take from the Space.
Note:this receive operation handler must be performed under a transaction.
Declaration Syntax
C# | Visual Basic | Visual C++ | J# |
public class ExclusiveReadReceiveOperationHandler<TData> : FifoGroupingReceiveHandler<TData>
Public Class ExclusiveReadReceiveOperationHandler(Of TData) _ Inherits FifoGroupingReceiveHandler(Of TData)
generic<typename TData> public ref class ExclusiveReadReceiveOperationHandler : public FifoGroupingReceiveHandler<TData>
Generic Template Parameters
- TData
- Type of data to receive.
Members
All Members | Constructors | Methods | Properties | ||
Icon | Member | Description |
---|---|---|
ExclusiveReadReceiveOperationHandler<(Of <(TData>)>)()()() | Initializes a new instance of the ExclusiveReadReceiveOperationHandler<(Of <(TData>)>) class | |
Equals(Object) | (Inherited from Object.) | |
Finalize()()() |
Allows an Object to attempt to free resources and perform other cleanup operations before the Object is reclaimed by garbage collection.
(Inherited from Object.) | |
GetHashCode()()() |
Serves as a hash function for a particular type.
(Inherited from Object.) | |
GetType()()() |
Gets the Type of the current instance.
(Inherited from Object.) | |
MemberwiseClone()()() |
Creates a shallow copy of the current Object.
(Inherited from Object.) | |
NonBlocking |
Gets or sets whether to perform the operation in a non blocking manner.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
NonBlockingFactor |
Gets or sets the non blocking factor if NonBlocking is true.
For instance if its value is 10 and the receive timeout of the operation is 1 seconds,
The operation will be executed 10 times with intervals of 100 miliseconds between each executions.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
Receive(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64) |
Performs the actual receive operation. Return values allowed are single object or an array of objects.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
ReceiveBatch(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32) |
Performs the actual receive operation. Return values allowed are single object or an array of objects.
(Inherited from NonBlockingReceiveHandler<(Of <(TData>)>).) | |
ReceiveBatchBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32) |
Executes receive operation logic in blocking mode
(Overrides NonBlockingReceiveHandler<(Of <(TData>)>).ReceiveBatchBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64, Int32).) | |
ReceiveBatchNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int32) |
Executes receive operation logic in non blocking mode
(Overrides NonBlockingReceiveHandler<(Of <(TData>)>).ReceiveBatchNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int32).) | |
ReceiveBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64) |
Executes receive operation logic in blocking mode
(Overrides NonBlockingReceiveHandler<(Of <(TData>)>).ReceiveBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction, Int64).) | |
ReceiveNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction) |
Executes receive operation logic in non blocking mode
(Overrides NonBlockingReceiveHandler<(Of <(TData>)>).ReceiveNonBlocking(IQuery<(Of <(TData>)>), ISpaceProxy, ITransaction).) | |
ToString()()() | (Inherited from Object.) | |
UseFifoGrouping |
Allows to configure the take/read operation to be performed in a Fifo Grouping manner.
If set to true, will use FifoGroupingPoll / FifoGroupingPoll as read/take modifiers.
(Inherited from FifoGroupingReceiveHandler<(Of <(TData>)>).) | |
UseMemoryOnlySearch |
Allows to configure the take/read operation to be performed in a memory only search manner.
If set to true, will use MemoryOnlySearch / MemoryOnlySearch as read/take modifiers.
(Inherited from MemoryOnlySearchReceiveHandler<(Of <(TData>)>).) |
Inheritance Hierarchy
Object | ||||
NonBlockingReceiveHandler<(Of <(TData>)>) | ||||
MemoryOnlySearchReceiveHandler<(Of <(TData>)>) | ||||
FifoGroupingReceiveHandler<(Of <(TData>)>) | ||||
ExclusiveReadReceiveOperationHandler<(Of <(TData>)>) |