Click or drag to resize

ProcessQueueT Methods

The ProcessQueueT type exposes the following members.

Methods
  Name Description
Public method Add Adds an item to the ProcessQueueT.
Public method AddRange Adds the elements of the specified collection to the end of the ProcessQueueT.
Public method BinarySearch(T) Searches the entire sorted ProcessQueueT, using a binary search algorithm, for an element using the default comparer and returns the zero-based index of the element.
Public method BinarySearch(T, IComparerT) Searches the entire sorted ProcessQueueT, using a binary search algorithm, for an element using the specified comparer and returns the zero-based index of the element.
Public method BinarySearch(Int32, Int32, T, IComparerT) Searches a range of elements in the sorted ProcessQueueT, using a binary search algorithm, for an element using the specified comparer and returns the zero-based index of the element.
Protected method CanProcessItem Determines if an item can be processed.
Protected method CanProcessItems Determines if all items can be processed.
Public method Clear Removes all elements from the ProcessQueueT.
Public method Contains Determines whether an element is in the ProcessQueueT.
Public method ConvertAllTOutput Converts the elements in the current ProcessQueueT to another type, and returns a ProcessQueueT containing the converted elements.
Public method CopyTo Copies the entire ProcessQueueT to a compatible one-dimensional array, starting at the beginning of the target array.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemFunctionSignature) Creates a new asynchronous ProcessQueueT with the default settings: ProcessInterval = 100, MaximumThreads = 5, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemsFunctionSignature) Creates a new asynchronous, bulk item ProcessQueueT with the default settings: ProcessInterval = 100, MaximumThreads = 5, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature) Creates a new asynchronous ProcessQueueT with the default settings: ProcessInterval = 100, MaximumThreads = 5, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemFunctionSignature, Int32) Creates a new asynchronous ProcessQueueT with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature) Creates a new asynchronous, bulk item ProcessQueueT with the default settings: ProcessInterval = 100, MaximumThreads = 5, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, Int32) Creates a new asynchronous, bulk item ProcessQueueT with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Int32) Creates a new asynchronous ProcessQueueT with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Int32) Creates a new asynchronous, bulk item ProcessQueueT with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemFunctionSignature, Double, Int32, Int32, Boolean, Boolean) Creates a new asynchronous ProcessQueueT using specified settings.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, Double, Int32, Int32, Boolean, Boolean) Creates a new asynchronous, bulk item ProcessQueueT using specified settings.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Double, Int32, Int32, Boolean, Boolean) Creates a new asynchronous ProcessQueueT using specified settings.
Public method Static member CreateAsynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Double, Int32, Int32, Boolean, Boolean) Creates a new asynchronous, bulk item ProcessQueueT using specified settings.
Public method Static member CreateRealTimeQueue(ProcessQueueTProcessItemFunctionSignature) Creates a new real-time ProcessQueueT with the default settings: ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateRealTimeQueue(ProcessQueueTProcessItemsFunctionSignature) Creates a new real-time, bulk item ProcessQueueT with the default settings: ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateRealTimeQueue(ProcessQueueTProcessItemFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature) Creates a new real-time ProcessQueueT with the default settings: ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateRealTimeQueue(ProcessQueueTProcessItemsFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature) Creates a new real-time, bulk item ProcessQueueT with the default settings: ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateRealTimeQueue(ProcessQueueTProcessItemFunctionSignature, Int32, Boolean, Boolean) Creates a new real-time ProcessQueueT using specified settings.
Public method Static member CreateRealTimeQueue(ProcessQueueTProcessItemsFunctionSignature, Int32, Boolean, Boolean) Creates a new real-time, bulk item ProcessQueueT using specified settings.
Public method Static member CreateRealTimeQueue(ProcessQueueTProcessItemFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Int32, Boolean, Boolean) Creates a new real-time ProcessQueueT using specified settings.
Public method Static member CreateRealTimeQueue(ProcessQueueTProcessItemsFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Int32, Boolean, Boolean) Creates a new real-time, bulk item ProcessQueueT using specified settings.
Public method Static member CreateSynchronousQueue(ProcessQueueTProcessItemFunctionSignature) Creates a new synchronous ProcessQueueT (i.e., single process thread) with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateSynchronousQueue(ProcessQueueTProcessItemsFunctionSignature) Creates a new synchronous, bulk item ProcessQueueT (i.e., single process thread) with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateSynchronousQueue(ProcessQueueTProcessItemFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature) Creates a new synchronous ProcessQueueT (i.e., single process thread) with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateSynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature) Creates a new synchronous, bulk item ProcessQueueT (i.e., single process thread) with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.
Public method Static member CreateSynchronousQueue(ProcessQueueTProcessItemFunctionSignature, Double, Int32, Boolean, Boolean) Creates a new synchronous ProcessQueueT (i.e., single process thread) using specified settings.
Public method Static member CreateSynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, Double, Int32, Boolean, Boolean) Creates a new synchronous, bulk item ProcessQueueT (i.e., single process thread) using specified settings.
Public method Static member CreateSynchronousQueue(ProcessQueueTProcessItemFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Double, Int32, Boolean, Boolean) Creates a new synchronous ProcessQueueT (i.e., single process thread) using specified settings.
Public method Static member CreateSynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Double, Int32, Boolean, Boolean) Creates a new synchronous, bulk item ProcessQueueT (i.e., single process thread) using specified settings.
Protected method DataAdded Notifies queue that data was added and/or modified, so it can begin processing data.
Public method Dispose Releases all the resources used by the ProcessQueueT object.
Protected method Dispose(Boolean) Releases the unmanaged resources used by the ProcessQueueT object and optionally releases the managed resources.
Public method Equals Determines whether the specified object is equal to the current object.
(Inherited from Object)
Public method Exists Determines whether the ProcessQueueT contains elements that match the conditions defined by the specified predicate.
Protected method Finalize Releases the unmanaged resources before the ProcessQueueT object is reclaimed by GC.
(Overrides ObjectFinalize)
Public method Find Searches for an element that matches the conditions defined by the specified predicate, and returns the first occurrence within the entire ProcessQueueT.
Public method FindAll Retrieves all elements that match the conditions defined by the specified predicate.
Public method FindIndex(PredicateT) Searches for an element that matches the conditions defined by the specified predicate, and returns the zero-based index of the first occurrence within the range of elements in the ProcessQueueT that extends from the specified index to the last element.
Public method FindIndex(Int32, PredicateT) Searches for an element that matches the conditions defined by the specified predicate, and returns the zero-based index of the first occurrence within the range of elements in the ProcessQueueT that extends from the specified index to the last element.
Public method FindIndex(Int32, Int32, PredicateT) Searches for an element that matches the conditions defined by the specified predicate, and returns the zero-based index of the first occurrence within the range of elements in the ProcessQueueT that extends from the specified index to the last element.
Public method FindLast Searches for an element that matches the conditions defined by the specified predicate, and returns the last occurrence within the entire ProcessQueueT.
Public method FindLastIndex(PredicateT) Searches for an element that matches the conditions defined by the specified predicate, and returns the zero-based index of the last occurrence within the entire ProcessQueueT.
Public method FindLastIndex(Int32, PredicateT) Searches for an element that matches the conditions defined by the specified predicate, and returns the zero-based index of the last occurrence within the range of elements in the ProcessQueueT that extends from the first element to the specified index.
Public method FindLastIndex(Int32, Int32, PredicateT) Searches for an element that matches the conditions defined by the specified predicate, and returns the zero-based index of the last occurrence within the range of elements in the ProcessQueueT that contains the specified number of elements and ends at the specified index.
Public method Flush Blocks the current thread, if the ProcessQueueT is active (i.e., user has called "Start" method), until all items in ProcessQueueT are processed, and then stops the ProcessQueueT.
Public method ForEach Performs the specified action on each element of the ProcessQueueT.
Public method GetEnumerator Returns an enumerator that iterates through the ProcessQueueT.
Public method GetHashCode Serves as the default hash function.
(Inherited from Object)
Public method GetRange Creates a shallow copy of a range of elements in the source ProcessQueueT.
Public method GetType Gets the Type of the current instance.
(Inherited from Object)
Public method IndexOf(T) Searches for the specified object and returns the zero-based index of the first occurrence within the entire ProcessQueueT.
Public method IndexOf(T, Int32) Searches for the specified object and returns the zero-based index of the first occurrence within the range of elements in the ProcessQueueT that extends from the specified index to the last element.
Public method IndexOf(T, Int32, Int32) Searches for the specified object and returns the zero-based index of the first occurrence within the range of elements in the ProcessQueueT that starts at the specified index and contains the specified number of elements.
Public method Insert Inserts an element into the ProcessQueueT at the specified index.
Public method InsertRange Inserts the elements of a collection into the ProcessQueueT at the specified index.
Public method LastIndexOf(T) Searches for the specified object and returns the zero-based index of the last occurrence within the entire ProcessQueueT.
Public method LastIndexOf(T, Int32) Searches for the specified object and returns the zero-based index of the last occurrence within the range of elements in the ProcessQueueT that extends from the first element to the specified index.
Public method LastIndexOf(T, Int32, Int32) Searches for the specified object and returns the zero-based index of the last occurrence within the range of elements in the ProcessQueueT that contains the specified number of elements and ends at the specified index.
Protected method MemberwiseClone Creates a shallow copy of the current Object.
(Inherited from Object)
Protected method OnItemProcessed Raises the base class ItemProcessed event.
Protected method OnItemsProcessed Raises the base class ItemsProcessed event.
Protected method OnItemsTimedOut Raises the base class ItemsTimedOut event.
Protected method OnItemTimedOut Raises the base class ItemTimedOut event.
Protected method OnProcessException Raises the base class ProcessException event.
Public method Remove Removes the first occurrence of a specific object from the ProcessQueueT.
Public method RemoveAll Removes the all the elements that match the conditions defined by the specified predicate.
Public method RemoveAt Removes the element at the specified index of the ProcessQueueT.
Public method RemoveRange Removes a range of elements from the ProcessQueueT.
Protected method RequeueItem Requeues item into ProcessQueueT according to specified requeue reason.
Protected method RequeueItems Requeues items into ProcessQueueT according to specified requeue reason.
Public method Reverse Reverses the order of the elements in the entire ProcessQueueT.
Public method Reverse(Int32, Int32) Reverses the order of the elements in the specified range.
Public method SignalDataModified Manually signals that data has been modified and processing should resume.
Public method Sort Sorts the elements in the entire ProcessQueueT, using the default comparer.
Public method Sort(ComparisonT) Sorts the elements in the entire ProcessQueueT, using the specified comparison.
Public method Sort(IComparerT) Sorts the elements in the entire ProcessQueueT, using the specified comparer.
Public method Sort(Int32, Int32, IComparerT) Sorts the elements in a range of elements in the ProcessQueueT, using the specified comparer.
Public method Start Starts item processing.
Public method Stop Stops item processing.
Public method ToArray Copies the elements contained in the ProcessQueueT to a new array.
Public method ToString Returns a string that represents the current object.
(Inherited from Object)
Public method TrueForAll Determines whether every element in the ProcessQueueT matches the conditions defined by the specified predicate.
Public method TryTake(T) Attempts to remove and return an object from the ProcessQueueT.
Public method TryTake(T) Attempts to remove and return all objects from the ProcessQueueT.
Top
Extension Methods
  Name Description
Public Extension Method AddRangeT Adds the specified items to the collection.
(Defined by CollectionExtensions)
Public Extension Method AllParallelT Determines whether all elements of a sequence satisfy a condition with each item being tested in parallel.
(Defined by CollectionExtensions)
Public Extension Method DistinctByT, TKey Returns only the elements whose keys are distinct.
(Defined by CollectionExtensions)
Public Extension Method GetEnumValueOrDefault Gets the enumeration constant for value, if defined in the enumeration, or a default value.
(Defined by EnumExtensions)
Public Extension Method GetEnumValueOrDefaultT Gets the enumeration constant for this value, if defined in the enumeration, or a default value.
(Defined by EnumExtensions)
Public Extension Method GetRangeT Returns elements in the specified range from the collection.
(Defined by CollectionExtensions)
Public Extension Method IndexOfT Returns the index of the first element of the sequence that satisfies a condition or -1 if no such element is found.
(Defined by CollectionExtensions)
Public Extension Method LoadDelimitedStringT Appends items parsed from delimited string, created with ToDelimitedString, using the default delimiter ("|") into the given list.
(Defined by CollectionExtensions)
Public Extension Method LoadDelimitedStringT Appends items parsed from delimited string, created with ToDelimitedString, into the given list.
(Defined by CollectionExtensions)
Public Extension Method LoadDelimitedStringT Appends items parsed from delimited string, created with ToDelimitedString, into the given list.
(Defined by CollectionExtensions)
Public Extension Method MajorityT Returns the majority value in the collection, or default type value if no item represents the majority.
(Defined by CollectionExtensions)
Public Extension Method MajorityT Returns the majority value in the collection, or defaultValue if no item represents the majority.
(Defined by CollectionExtensions)
Public Extension Method MajorityByT, TKey Returns the majority value in the collection, or default type value if no item represents the majority.
(Defined by CollectionExtensions)
Public Extension Method MajorityByT, TKey Returns the majority value in the collection, or defaultValue if no item represents the majority.
(Defined by CollectionExtensions)
Public Extension Method MaxT Returns the largest item from the enumeration.
(Defined by CollectionExtensions)
Public Extension Method MaxT Returns the largest item from the enumeration.
(Defined by CollectionExtensions)
Public Extension Method MaxByT, TKey Selects the largest item from the enumeration.
(Defined by CollectionExtensions)
Public Extension Method MedianT Gets the median item(s) from an enumeration, i.e., one return item for odd lengths, two for even lengths.
(Defined by CollectionExtensions)
Public Extension Method MiddleT Gets the middle item(s) from an enumeration, i.e., one return item for odd lengths, two for even lengths.
(Defined by CollectionExtensions)
Public Extension Method MinT Returns the smallest item from the enumeration.
(Defined by CollectionExtensions)
Public Extension Method MinT Returns the smallest item from the enumeration.
(Defined by CollectionExtensions)
Public Extension Method MinByT, TKey Selects the smallest item from the enumeration.
(Defined by CollectionExtensions)
Public Extension Method MinorityT Returns the minority value in the collection, or default type value if no item represents the minority.
(Defined by CollectionExtensions)
Public Extension Method MinorityT Returns the minority value in the collection, or defaultValue if no item represents the minority.
(Defined by CollectionExtensions)
Public Extension Method MinorityByT, TKey Returns the minority value in the collection, or default type value if no item represents the majority.
(Defined by CollectionExtensions)
Public Extension Method MinorityByT, TKey Returns the minority value in the collection, or defaultValue if no item represents the majority.
(Defined by CollectionExtensions)
Public Extension Method ScrambleT Rearranges all the elements in the list into a highly-random order.
(Defined by CollectionExtensions)
Public Extension Method ScrambleT Rearranges all the elements in the list into a repeatable pseudo-random order.
(Defined by CollectionExtensions)
Public Extension Method StandardDeviationT Computes the standard deviation over a sequence of Double values.
(Defined by NumericalAnalysisExtensions)
Public Extension Method StandardDeviationT Computes the standard deviation over a sequence of Decimal values.
(Defined by NumericalAnalysisExtensions)
Public Extension Method StandardDeviationT Computes the standard deviation over a sequence of Single values.
(Defined by NumericalAnalysisExtensions)
Public Extension Method ToDelimitedStringT Converts an enumeration to a string, using the default delimiter ("|") that can later be converted back to a list using LoadDelimitedString.
(Defined by CollectionExtensions)
Public Extension Method ToDelimitedStringT Converts an enumeration to a string that can later be converted back to a list using LoadDelimitedString.
(Defined by CollectionExtensions)
Public Extension Method ToDelimitedStringT Converts an enumeration to a string that can later be converted back to a list using LoadDelimitedString.
(Defined by CollectionExtensions)
Public Extension Method ToPagedListT Gets a PagedListT to paginate source enumeration for a given page and specified pageSize.
(Defined by CollectionExtensions)
Public Extension Method UnscrambleT Rearranges all the elements in the list previously scrambled with ScrambleTSource(IListTSource, Int32) back into their original order.
(Defined by CollectionExtensions)
Public Extension Method UpdateRangeT Updates collection starting at the index with the specified items.
(Defined by CollectionExtensions)
Top
See Also