Home
last modified time | relevance | path

Searched refs:BlockingCollection (Results 1 – 25 of 56) sorted by relevance

123

/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/tests/
H A DBlockingCollectionTests.cs22 BlockingCollection<int> bc = new BlockingCollection<int>(3); in TestBasicScenarios()
62 BlockingCollection<object> bc = new BlockingCollection<object>(); in TestBugFix544259()
179 BlockingCollection<int> col = new BlockingCollection<int> { 1, 2, 3 }; in TestDebuggerAttributes()
379 … BlockingCollection<int>[] blockingCollections = new BlockingCollection<int>[NUM_OF_COLLECTIONS]; in Test4_Dispose()
729 …BlockingCollection<int>[] blockingCollections = new BlockingCollection<int>[numOfBlockingCollectio… in TestAddAnyTakeAny()
760 … BlockingCollection<int>[] blockingCollections = new BlockingCollection<int>[numOfCollections]; in TestConcurrentAddAnyTakeAny()
863 BlockingCollection<int> bc = new BlockingCollection<int>(new QueueProxy1<int>()); in Test17_AddExceptions()
891 … BlockingCollection<int>[] blockingCollections = new BlockingCollection<int>[NUM_OF_COLLECTIONS]; in Test19_AddAnyExceptions()
912 … BlockingCollection<int> collection = new BlockingCollection<int>(new QueueProxy1<int>()); in Test19_AddAnyExceptions()
922 … BlockingCollection<int>[] blockingCollections = new BlockingCollection<int>[NUM_OF_COLLECTIONS]; in Test20_TakeAnyExceptions()
[all …]
H A DBlockingCollectionCancellationTests.cs17 BlockingCollection<int> coll1 = new BlockingCollection<int>(); in InternalCancellation_CompleteAdding_Negative()
35 BlockingCollection<int> coll1 = new BlockingCollection<int>(1); in InternalCancellation_WakingUp()
67 BlockingCollection<int> bc = new BlockingCollection<int>(); //empty collection. in ExternalCancel_Negative()
87 BlockingCollection<int> bc1 = new BlockingCollection<int>(1); in ExternalCancel_Negative()
88 BlockingCollection<int> bc2 = new BlockingCollection<int>(1); in ExternalCancel_Negative()
92 () => BlockingCollection<int>.AddToAny(new[] { bc1, bc2 }, 1, cs.Token), in ExternalCancel_Negative()
96 () => BlockingCollection<int>.TryAddToAny(new[] { bc1, bc2 }, 1, 10000, cs.Token), in ExternalCancel_Negative()
111 BlockingCollection<int> bc1 = new BlockingCollection<int>(1); in ExternalCancel_AddToAny()
112 BlockingCollection<int> bc2 = new BlockingCollection<int>(1); in ExternalCancel_AddToAny()
125 BlockingCollection<int>.AddToAny(new[] { bc1, bc2 }, 42, cs.Token); in ExternalCancel_AddToAny()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Collections.Concurrent/
H A DBlockingCollectionTests.cs38 BlockingCollection<int> defaultCollection;
39 BlockingCollection<int> boundedCollection;
44 defaultCollection = new BlockingCollection<int>(); in Setup()
45 boundedCollection = new BlockingCollection<int>(10); in Setup()
190 var queue = new BlockingCollection<object> (); in EmptyTryTakeWithTimeout()
199 var a = new BlockingCollection<string> (); in TakeAnyFromSecondCollection()
200 var b = new BlockingCollection<string> (); in TakeAnyFromSecondCollection()
218 var a = new BlockingCollection<string> (); in TakeAnyCancellable()
219 var b = new BlockingCollection<string> (); in TakeAnyCancellable()
255 var c = new BlockingCollection <int> (elNumber); in BoundedAddLimit()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/src/System/Collections/Concurrent/
H A DBlockingCollection.cs44 …public class BlockingCollection<T> : IEnumerable<T>, ICollection, IDisposable, IReadOnlyCollection… class
145 public BlockingCollection() in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
160 public BlockingCollection(int boundedCapacity) in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
175 public BlockingCollection(IProducerConsumerCollection<T> collection, int boundedCapacity) in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
201 public BlockingCollection(IProducerConsumerCollection<T> collection) in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
794 public static int AddToAny(BlockingCollection<T>[] collections, T item) in AddToAny()
869 public static int TryAddToAny(BlockingCollection<T>[] collections, T item) in TryAddToAny()
1060 private static int TryAddToAnyFast(BlockingCollection<T>[] collections, T item) in TryAddToAnyFast()
1173 public static int TakeFromAny(BlockingCollection<T>[] collections, out T item) in TakeFromAny()
1230 public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item) in TryTakeFromAny()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/sys/system/collections/concurrent/
H A DBlockingCollection.cs56 …public class BlockingCollection<T> : IEnumerable<T>, ICollection, IDisposable, IReadOnlyCollection… class
157 public BlockingCollection() in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
172 public BlockingCollection(int boundedCapacity) in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
187 public BlockingCollection(IProducerConsumerCollection<T> collection, int boundedCapacity) in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
213 public BlockingCollection(IProducerConsumerCollection<T> collection) in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
805 public static int AddToAny(BlockingCollection<T>[] collections, T item) in AddToAny()
880 public static int TryAddToAny(BlockingCollection<T>[] collections, T item) in TryAddToAny()
1071 private static int TryAddToAnyFast(BlockingCollection<T>[] collections, T item) in TryAddToAnyFast()
1186 public static int TakeFromAny(BlockingCollection<T>[] collections, out T item) in TakeFromAny()
1244 public static int TryTakeFromAny(BlockingCollection<T>[] collections, out T item) in TryTakeFromAny()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/ref/
H A DSystem.Collections.Concurrent.cs13 public BlockingCollection() { } in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
14 …public BlockingCollection(System.Collections.Concurrent.IProducerConsumerCollection<T> collection)… in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
15 …public BlockingCollection(System.Collections.Concurrent.IProducerConsumerCollection<T> collection,… in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
16 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() method in System.Collections.Concurrent.BlockingCollection
25 …public static int AddToAny(System.Collections.Concurrent.BlockingCollection<T>[] collections, T it… in AddToAny()
38 …public static int TakeFromAny(System.Collections.Concurrent.BlockingCollection<T>[] collections, o… in TakeFromAny()
45 …public static int TryAddToAny(System.Collections.Concurrent.BlockingCollection<T>[] collections, T… in TryAddToAny()
46 …public static int TryAddToAny(System.Collections.Concurrent.BlockingCollection<T>[] collections, T… in TryAddToAny()
48 …public static int TryAddToAny(System.Collections.Concurrent.BlockingCollection<T>[] collections, T… in TryAddToAny()
53 …public static int TryTakeFromAny(System.Collections.Concurrent.BlockingCollection<T>[] collections… in TryTakeFromAny()
[all …]
/dports/devel/grpc/grpc-1.42.0/src/csharp/Grpc.Microbenchmarks/
H A DCommonThreadedBase.cs47 private List<BlockingCollection<Action>> dispatchQueues;
52 dispatchQueues = new List<BlockingCollection<Action>>(); in Setup()
56 var dispatchQueue = new BlockingCollection<Action>(); in Setup()
115 private void WorkerThreadBody(BlockingCollection<Action> dispatchQueue) in WorkerThreadBody()
/dports/devel/grpc130/grpc-1.30.2/src/csharp/Grpc.Microbenchmarks/
H A DCommonThreadedBase.cs47 private List<BlockingCollection<Action>> dispatchQueues;
52 dispatchQueues = new List<BlockingCollection<Action>>(); in Setup()
56 var dispatchQueue = new BlockingCollection<Action>(); in Setup()
115 private void WorkerThreadBody(BlockingCollection<Action> dispatchQueue) in WorkerThreadBody()
/dports/devel/grpc134/grpc-1.34.1/src/csharp/Grpc.Microbenchmarks/
H A DCommonThreadedBase.cs47 private List<BlockingCollection<Action>> dispatchQueues;
52 dispatchQueues = new List<BlockingCollection<Action>>(); in Setup()
56 var dispatchQueue = new BlockingCollection<Action>(); in Setup()
115 private void WorkerThreadBody(BlockingCollection<Action> dispatchQueue) in WorkerThreadBody()
/dports/devel/godot-tools/godot-3.2.3-stable/modules/mono/glue/GodotSharp/GodotSharp/Core/
H A DGodotSynchronizationContext.cs9 …private readonly BlockingCollection<KeyValuePair<SendOrPostCallback, object>> _queue = new Blockin…
/dports/devel/godot/godot-3.2.3-stable/modules/mono/glue/GodotSharp/GodotSharp/Core/
H A DGodotSynchronizationContext.cs9 …private readonly BlockingCollection<KeyValuePair<SendOrPostCallback, object>> _queue = new Blockin…
/dports/lang/mono/mono-5.10.1.57/mono/tests/
H A Dsgen-new-threads-collect.cs28 …BlockingCollection<Thread> threads = new BlockingCollection<Thread> (new ConcurrentQueue<Thread> (… in Main()
H A Dsgen-new-threads-dont-join-stw-2.cs11 BlockingCollection<Thread> threads = new BlockingCollection<Thread> (128); in Main()
/dports/lang/mono/mono-5.10.1.57/mcs/class/Facades/System.Collections.Concurrent/
H A DTypeForwarders.cs23 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.7/Facades/
H A DSystem.Collections.Concurrent.cs15 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.7.1/Facades/
H A DSystem.Collections.Concurrent.cs16 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5.2/Facades/
H A DSystem.Collections.Concurrent.cs16 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5/Facades/
H A DSystem.Collections.Concurrent.cs16 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5.1/Facades/
H A DSystem.Collections.Concurrent.cs16 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6/Facades/
H A DSystem.Collections.Concurrent.cs18 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6.2/Facades/
H A DSystem.Collections.Concurrent.cs18 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6.1/Facades/
H A DSystem.Collections.Concurrent.cs18 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/net_4_x/Facades/
H A DSystem.Collections.Concurrent.cs17 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/monodroid/Facades/
H A DSystem.Collections.Concurrent.cs17 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]
/dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/monotouch/Facades/
H A DSystem.Collections.Concurrent.cs17 …pilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.BlockingCollection<>))]

123