| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/ |
| H A D | BufferBlockTests.cs | 75 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1 }) in TestPost()
216 for (int boundedCapacity = 1; boundedCapacity <= 3; boundedCapacity++) in TestCircularLinking()
219 b.PostRange(0, boundedCapacity); in TestCircularLinking()
224 Assert.Equal(expected: boundedCapacity, actual: b.Count); in TestCircularLinking()
238 BoundedCapacity = boundedCapacity, in TestProducerConsumer()
264 foreach (int boundedCapacity in new[] { 1, 3 }) in TestMessagePostponement()
269 var sendAsync = new Task<bool>[boundedCapacity + Excess]; in TestMessagePostponement()
270 for (int i = 0; i < boundedCapacity + Excess; i++) in TestMessagePostponement()
274 for (int i = 0; i < boundedCapacity; i++) in TestMessagePostponement()
282 Assert.False(await sendAsync[boundedCapacity + i]); in TestMessagePostponement()
[all …]
|
| H A D | TransformManyBlockTests.cs | 192 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestProducerConsumer()
200 BoundedCapacity = boundedCapacity, in TestProducerConsumer()
237 foreach (int boundedCapacity in new[] { 1, 3 }) in TestMessagePostponement()
239 … var options = new ExecutionDataflowBlockOptions { BoundedCapacity = boundedCapacity }; in TestMessagePostponement()
244 var sendAsync = new Task<bool>[boundedCapacity + Excess]; in TestMessagePostponement()
245 for (int i = 0; i < boundedCapacity + Excess; i++) in TestMessagePostponement()
251 for (int i = 0; i < boundedCapacity; i++) in TestMessagePostponement()
259 Assert.False(await sendAsync[boundedCapacity + i]); in TestMessagePostponement()
565 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestYieldingNoResults()
579 …ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = dop, BoundedCapacity = boundedCapacity }); in TestYieldingNoResults()
[all …]
|
| H A D | TransformBlockTests.cs | 189 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestProducerConsumer()
196 BoundedCapacity = boundedCapacity, in TestProducerConsumer()
228 foreach (int boundedCapacity in new[] { 1, 3 }) in TestMessagePostponement()
230 … var options = new ExecutionDataflowBlockOptions { BoundedCapacity = boundedCapacity }; in TestMessagePostponement()
233 var sendAsync = new Task<bool>[boundedCapacity + Excess]; in TestMessagePostponement()
234 for (int i = 0; i < boundedCapacity + Excess; i++) in TestMessagePostponement()
240 for (int i = 0; i < boundedCapacity; i++) in TestMessagePostponement()
248 Assert.False(await sendAsync[boundedCapacity + i]); in TestMessagePostponement()
|
| H A D | BatchBlockTests.cs | 81 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1 }) in TestPost()
83 … var bb = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = boundedCapacity }); in TestPost()
231 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 2, 3 }) in TestProducerConsumer()
237 BoundedCapacity = boundedCapacity, in TestProducerConsumer()
362 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 3 }) in TestBoundedCapacityFromSends()
365 …chBlock<int>(2, new GroupingDataflowBlockOptions { BoundedCapacity = boundedCapacity, Greedy = gre… in TestBoundedCapacityFromSends()
|
| H A D | JoinBlockTests.cs | 441 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 2, 3 }) in TestMaxNumberOfGroups()
459 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1 }) in TestTree()
465 BoundedCapacity = boundedCapacity, in TestTree()
|
| H A D | WriteOnceBlockTests.cs | 146 foreach (int boundedCapacity in new[] { DataflowBlockOptions.Unbounded, 1, 2 }) in TestPost()
148 …eOnceBlock<int>(i => i, new DataflowBlockOptions { BoundedCapacity = boundedCapacity }); // option… in TestPost()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/tests/ |
| H A D | BlockingCollectionTests.cs | 202 public static void TestConstruction(int boundedCapacity) in TestConstruction() argument
205 if (boundedCapacity != -1) in TestConstruction()
207 blockingQueue = new BlockingCollection<int>(boundedCapacity); in TestConstruction()
214 Assert.Equal(boundedCapacity, blockingQueue.BoundedCapacity); in TestConstruction()
217 int count = boundedCapacity != -1 ? boundedCapacity : 10; in TestConstruction()
251 TestAddTake(numOfAdds, numOfTakes, boundedCapacity); in TestAddTake_Longrunning()
401 int? boundedCapacity = 0; in Test4_Dispose()
726 int boundedCapacity) in TestAddAnyTakeAny() argument
988 int boundedCapacity, in AddAnyTakeAny() argument
1014 int capacity = (boundedCapacity == -1) ? Int32.MaxValue : boundedCapacity; in AddAnyTakeAny()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/src/System/Collections/Concurrent/ |
| H A D | BlockingCollection.cs | 160 public BlockingCollection(int boundedCapacity) in BlockingCollection() argument
161 : this(new ConcurrentQueue<T>(), boundedCapacity) in BlockingCollection()
177 if (boundedCapacity < 1) in BlockingCollection()
180 nameof(boundedCapacity), boundedCapacity, in BlockingCollection()
188 if (count > boundedCapacity) in BlockingCollection()
192 Initialize(collection, boundedCapacity, count); in BlockingCollection()
216 Debug.Assert(boundedCapacity > 0 || boundedCapacity == NON_BOUNDED); in Initialize()
219 _boundedCapacity = boundedCapacity; ; in Initialize()
224 if (boundedCapacity == NON_BOUNDED) in Initialize()
230 Debug.Assert(boundedCapacity > 0); in Initialize()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/sys/system/collections/concurrent/ |
| H A D | BlockingCollection.cs | 172 public BlockingCollection(int boundedCapacity) in BlockingCollection() argument
173 : this(new ConcurrentQueue<T>(), boundedCapacity) in BlockingCollection()
189 if (boundedCapacity < 1) in BlockingCollection()
192 "boundedCapacity", boundedCapacity, in BlockingCollection()
200 if (count > boundedCapacity) in BlockingCollection()
204 Initialize(collection, boundedCapacity, count); in BlockingCollection()
228 Debug.Assert(boundedCapacity > 0 || boundedCapacity == NON_BOUNDED); in Initialize()
231 m_boundedCapacity = boundedCapacity; ; in Initialize()
236 if (boundedCapacity == NON_BOUNDED) in Initialize()
242 Debug.Assert(boundedCapacity > 0); in Initialize()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Internal/ |
| H A D | Common.cs | 630 internal BoundingState(int boundedCapacity) in BoundingState() argument
632 Debug.Assert(boundedCapacity > 0, "Bounded is only supported with positive values."); in BoundingState()
633 BoundedCapacity = boundedCapacity; in BoundingState()
666 internal BoundingStateWithPostponed(int boundedCapacity) : base(boundedCapacity) in BoundingStateWithPostponed() argument
683 internal BoundingStateWithPostponedAndTask(int boundedCapacity) : base(boundedCapacity) in BoundingStateWithPostponedAndTask() argument
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Internal/ |
| H A D | Common.cs | 628 internal BoundingState(int boundedCapacity) in BoundingState() argument
630 … Contract.Requires(boundedCapacity > 0, "Bounded is only supported with positive values."); in BoundingState()
631 BoundedCapacity = boundedCapacity; in BoundingState()
664 internal BoundingStateWithPostponed(int boundedCapacity) : base(boundedCapacity) in BoundingStateWithPostponed() argument
681 internal BoundingStateWithPostponedAndTask(int boundedCapacity) : base(boundedCapacity) in BoundingStateWithPostponedAndTask() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/ref/ |
| H A D | System.Collections.Concurrent.cs | 15 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
16 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/monotouch/ |
| H A D | System.cs | 366 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
367 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/monotouch/ |
| H A D | System.cs | 369 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
370 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/monodroid/ |
| H A D | System.cs | 364 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
365 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/monodroid/ |
| H A D | System.cs | 365 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
366 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.0/ |
| H A D | System.cs | 2026 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
2027 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5.2/ |
| H A D | System.cs | 1814 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
1815 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6.1/ |
| H A D | System.cs | 1831 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
1832 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6/ |
| H A D | System.cs | 1831 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
1832 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5.1/ |
| H A D | System.cs | 1814 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
1815 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5/ |
| H A D | System.cs | 1814 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
1815 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/net_4_x/ |
| H A D | System.cs | 1823 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
1824 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.7.1/ |
| H A D | System.cs | 2087 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
2088 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|
| /dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6.2/ |
| H A D | System.cs | 1831 …n(System.Collections.Concurrent.IProducerConsumerCollection<T> collection, int boundedCapacity) { } in BlockingCollection() argument
1832 public BlockingCollection(int boundedCapacity) { } in BlockingCollection() argument
|