Home
last modified time | relevance | path

Searched refs:ConcurrentBag (Results 1 – 25 of 46) sorted by relevance

12

/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/tests/Performance/
H A DPerf.ConcurrentBag.cs25 new ConcurrentBag<int>(); // 1 in Ctor()
26 new ConcurrentBag<int>(); // 2 in Ctor()
27 new ConcurrentBag<int>(); // 3 in Ctor()
28 new ConcurrentBag<int>(); // 4 in Ctor()
29 new ConcurrentBag<int>(); // 5 in Ctor()
30 new ConcurrentBag<int>(); // 6 in Ctor()
46 var q = new ConcurrentBag<int>(); in Add()
66 var b = new ConcurrentBag<int>(); in TryTake()
92 var b = new ConcurrentBag<int>(); in AddTake()
114 var b = new ConcurrentBag<int>(); in Pooling_AddTakeFromSameThreads()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/tests/
H A DConcurrentBagTests.cs15 …ide IProducerConsumerCollection<T> CreateProducerConsumerCollection<T>() => new ConcurrentBag<T>(); in CreateProducerConsumerCollection()
17 …protected override bool IsEmpty(IProducerConsumerCollection<int> pcc) => ((ConcurrentBag<int>)pcc)…
18 …ool TryPeek<T>(IProducerConsumerCollection<T> pcc, out T result) => ((ConcurrentBag<T>)pcc).TryPee… in TryPeek()
29 var bag = new ConcurrentBag<int>(); in AddThenPeek_LatestLocalItemReturned()
52 var bag = new ConcurrentBag<int>(Enumerable.Range(1, 5)); in AddOnOneThread_PeekOnAnother_EnsureWeCanTakeOnTheOriginal()
83 var bag = new ConcurrentBag<int>(Enumerable.Range(0, 100000)); in AddManyItems_ThenTakeOnDifferentThread_ItemsOutputInExpectedOrder()
102 var bag = new ConcurrentBag<int>(Enumerable.Range(0, initialCount)); in IterativelyAddOnOneThreadThenTakeOnAnother_OrderMaintained()
137 … var c = new ConcurrentBag<Exception>(Enumerable.Range(0, Size).Select(_ => new Exception())); in CopyTo_TypeMismatch()
148 … c = new ConcurrentBag<Exception>(Enumerable.Range(0, Size).Select(_ => new Exception())); in ICollectionCopyTo_TypeMismatch()
152 …c = new ConcurrentBag<ArgumentException>(Enumerable.Range(0, Size).Select(_ => new ArgumentExcepti… in ICollectionCopyTo_TypeMismatch()
[all …]
H A DConcurrentBagTests.netcoreapp.cs24 var bag = new ConcurrentBag<int>(); in Clear_AddItemsToThisAndOtherThreads_EmptyAfterClear()
56 var bag = new ConcurrentBag<int>(Enumerable.Range(0, ExpectedCount)); in Clear_DuringEnumeration_DoesntAffectEnumeration()
72 var bag = new ConcurrentBag<int>(); in Clear_ConcurrentUsage_NoExceptions()
H A DEtwTests.cs35 var cb = new ConcurrentBag<int>(); in TestEtw()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Parallel/tests/
H A DRangePartitionerThreadSafetyTests.cs31 …ConcurrentBag<OrderablePartitioner<Tuple<int, int>>> bag = new ConcurrentBag<OrderablePartitioner<… in IntPartitionerThreadSafety()
67 …ConcurrentBag<OrderablePartitioner<Tuple<long, long>>> bag = new ConcurrentBag<OrderablePartitione… in LongPartitionerThreadSafety()
H A DRangePartitioner1Chunk.cs294 …private ConcurrentBag<UserActionEnumerator<T>> _allEnumerators = new ConcurrentBag<UserActionEnume…
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Composition.TypedParts/tests/
H A DReflectionTests.cs33 var errors = new ConcurrentBag<Exception>(); in MultiThreadedGetExportsWorkWithImportingConstuctor()
62 private static void Run(ManualResetEventSlim evnt, ConcurrentBag<Exception> errors) in Run()
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Collections.Concurrent/
H A DConcurrentBagTests.cs45 ConcurrentBag<int> bag;
50 bag = new ConcurrentBag<int> (); in Setup()
254 var bag = new ConcurrentBag<int> (); in Bug24213()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/sys/system/collections/concurrent/
H A DConcurrentBag.cs58 public class ConcurrentBag<T> : IProducerConsumerCollection<T>, IReadOnlyCollection<T> class
89 public ConcurrentBag() in ConcurrentBag() method in System.Collections.Concurrent.ConcurrentBag
102 public ConcurrentBag(IEnumerable<T> collection) in ConcurrentBag() method in System.Collections.Concurrent.ConcurrentBag
616 return ((ConcurrentBag<T>)this).GetEnumerator(); in IEnumerable.GetEnumerator()
/dports/lang/mono/mono-5.10.1.57/mcs/class/Facades/System.Collections.Concurrent/
H A DTypeForwarders.cs24 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/src/System/Collections/Concurrent/
H A DConcurrentBag.cs33 public class ConcurrentBag<T> : IProducerConsumerCollection<T>, IReadOnlyCollection<T> class
41 public ConcurrentBag() in ConcurrentBag() method in System.Collections.Concurrent.ConcurrentBag
54 public ConcurrentBag(IEnumerable<T> collection) in ConcurrentBag() method in System.Collections.Concurrent.ConcurrentBag
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.7/Facades/
H A DSystem.Collections.Concurrent.cs16 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.7.1/Facades/
H A DSystem.Collections.Concurrent.cs17 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5.2/Facades/
H A DSystem.Collections.Concurrent.cs17 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5/Facades/
H A DSystem.Collections.Concurrent.cs17 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.5.1/Facades/
H A DSystem.Collections.Concurrent.cs17 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6/Facades/
H A DSystem.Collections.Concurrent.cs19 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6.2/Facades/
H A DSystem.Collections.Concurrent.cs19 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/binary-reference-assemblies/src/v4.6.1/Facades/
H A DSystem.Collections.Concurrent.cs19 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/net_4_x/Facades/
H A DSystem.Collections.Concurrent.cs18 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/monodroid/Facades/
H A DSystem.Collections.Concurrent.cs18 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/monotouch/Facades/
H A DSystem.Collections.Concurrent.cs18 …e.CompilerServices.TypeForwardedToAttribute(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/ref/
H A DSystem.Collections.Concurrent.cs58 …public partial class ConcurrentBag<T> : System.Collections.Concurrent.IProducerConsumerCollection<… class
60 public ConcurrentBag() { } in ConcurrentBag() method in System.Collections.Concurrent.ConcurrentBag
61 public ConcurrentBag(System.Collections.Generic.IEnumerable<T> collection) { } in ConcurrentBag() method in System.Collections.Concurrent.ConcurrentBag
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Configuration.ConfigurationManager/tests/System/Configuration/
H A DTypeUtilTests.cs31 InlineData("System.Collections.Concurrent.ConcurrentBag`1", typeof(ConcurrentBag<>)),
/dports/lang/mono/mono-5.10.1.57/external/aspnetwebstack/src/System.Web.Http.SelfHost/
H A DHttpSelfHostServer.cs37 private ConcurrentBag<IReplyChannel> _channels = new ConcurrentBag<IReplyChannel>();

12