Lean
$LEAN_TAG$
|
A non blocking IBusyCollection<T> implementation More...
Public Member Functions | |
void | Add (T item) |
Adds the items to this collection More... | |
void | Add (T item, CancellationToken cancellationToken) |
Adds the items to this collection More... | |
IEnumerable< T > | GetConsumingEnumerable () |
Provides a consuming enumerable for items in this collection. More... | |
IEnumerable< T > | GetConsumingEnumerable (CancellationToken cancellationToken) |
Provides a consuming enumerable for items in this collection. More... | |
void | Dispose () |
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. More... | |
void | CompleteAdding () |
Marks the collection as not accepting any more additions More... | |
Public Attributes | |
WaitHandle | WaitHandle => _processingCompletedEvent.WaitHandle |
Gets a wait handle that can be used to wait until this instance is done processing all of it's item More... | |
int | Count => _collection.Count |
Gets the number of items held within this collection More... | |
bool | IsBusy => !_collection.IsEmpty || !_processingCompletedEvent.IsSet |
Returns true if processing, false otherwise More... | |
Additional Inherited Members | |
Properties inherited from QuantConnect.Interfaces.IBusyCollection< T > | |
WaitHandle | WaitHandle [get] |
Gets a wait handle that can be used to wait until this instance is done processing all of it's item More... | |
int | Count [get] |
Gets the number of items held within this collection More... | |
bool | IsBusy [get] |
Returns true if processing, false otherwise More... | |
A non blocking IBusyCollection<T> implementation
T | The item type being processed |
Definition at line 29 of file BusyCollection.cs.
void QuantConnect.Util.BusyCollection< T >.Add | ( | T | item | ) |
Adds the items to this collection
item | The item to be added |
Implements QuantConnect.Interfaces.IBusyCollection< T >.
Definition at line 55 of file BusyCollection.cs.
void QuantConnect.Util.BusyCollection< T >.Add | ( | T | item, |
CancellationToken | cancellationToken | ||
) |
Adds the items to this collection
item | The item to be added |
cancellationToken | A cancellation token to observer |
Implements QuantConnect.Interfaces.IBusyCollection< T >.
Definition at line 65 of file BusyCollection.cs.
IEnumerable<T> QuantConnect.Util.BusyCollection< T >.GetConsumingEnumerable | ( | ) |
Provides a consuming enumerable for items in this collection.
Implements QuantConnect.Interfaces.IBusyCollection< T >.
Definition at line 86 of file BusyCollection.cs.
IEnumerable<T> QuantConnect.Util.BusyCollection< T >.GetConsumingEnumerable | ( | CancellationToken | cancellationToken | ) |
Provides a consuming enumerable for items in this collection.
cancellationToken | A cancellation token to observer |
Implements QuantConnect.Interfaces.IBusyCollection< T >.
Definition at line 96 of file BusyCollection.cs.
void QuantConnect.Util.BusyCollection< T >.Dispose | ( | ) |
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
<filterpriority>2</filterpriority>
Definition at line 118 of file BusyCollection.cs.
void QuantConnect.Util.BusyCollection< T >.CompleteAdding | ( | ) |
Marks the collection as not accepting any more additions
Implements QuantConnect.Interfaces.IBusyCollection< T >.
Definition at line 127 of file BusyCollection.cs.
WaitHandle QuantConnect.Util.BusyCollection< T >.WaitHandle => _processingCompletedEvent.WaitHandle |
Gets a wait handle that can be used to wait until this instance is done processing all of it's item
Definition at line 39 of file BusyCollection.cs.
int QuantConnect.Util.BusyCollection< T >.Count => _collection.Count |
Gets the number of items held within this collection
Definition at line 44 of file BusyCollection.cs.
bool QuantConnect.Util.BusyCollection< T >.IsBusy => !_collection.IsEmpty || !_processingCompletedEvent.IsSet |
Returns true if processing, false otherwise
Definition at line 49 of file BusyCollection.cs.