Home
last modified time | relevance | path

Searched refs:TryTake (Results 1 – 25 of 89) sorted by relevance

1234

/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Collections.Concurrent/
H A DConcurrentBagTests.cs65 Assert.IsTrue (bag.TryTake (out result)); in BasicAddTakeTest()
85 Assert.IsTrue (bag.TryTake (out result)); in BasicAddTakeFromOtherThread()
111 Assert.IsTrue (bag.TryTake (out result)); in AddFromMultipleThreadTakeFromOneThread()
131 threads[i] = new Thread (() => valid &= bag.TryTake (out result) && result == 1); in AddFromOneThreadTakeFromMultiple()
199 Assert.IsFalse(bag.TryTake(out result)); in BasicRemoveEmptyTest()
210 Assert.IsTrue (bag.TryTake (out result)); in BasicRemoveTwiceTest()
213 Assert.IsFalse (bag.TryTake (out result)); in BasicRemoveTwiceTest()
214 Assert.IsFalse (bag.TryTake (out result)); in BasicRemoveTwiceTest()
225 Assert.IsTrue (bag.TryTake (out result)); in AddRemoveAddTest()
233 Assert.IsTrue (bag.TryTake (out result)); in AddRemoveAddTest()
H A DCollectionStressTestHelper.cs66 while (coll.TryTake (out temp)) { in AddStressTest()
97 s &= coll.TryTake (out t); in RemoveStressTest()
99 if (!s && coll.TryTake (out t)) in RemoveStressTest()
113 while (coll.TryTake (out temp)) { in RemoveStressTest()
H A DBlockingCollectionTests.cs176 bool firstTake = defaultCollection.TryTake (out value); in TryTakeTestCase()
178 bool secondTake = defaultCollection.TryTake (out value2); in TryTakeTestCase()
191 bool success = queue.TryTake (out o, 500); in EmptyTryTakeWithTimeout()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/tests/
H A DProducerConsumerCollectionTests.cs96 Assert.False(pcc.TryTake(out item)); in Ctor_InitializeFromCollection_ContainsExpectedItems()
182 Assert.Equal(oracle.TryTake(out expected), c.TryTake(out actual)); in AddTake_RandomChangesMatchOracle()
241 Assert.Equal(oracle.TryTake(out expected), c.TryTake(out actual)); in ToArray_AddAllItemsThenEnumerate_ItemsAndCountMatch()
266 Assert.Equal(oracle.TryTake(out expected), c.TryTake(out actual)); in ToArray_AddAndTakeItemsIntermixedWithEnumeration_ItemsAndCountMatch()
306 Assert.Equal(oracle.TryTake(out expected), c.TryTake(out actual)); in AddManyItems_ThenTakeOnSameThread_ItemsOutputInExpectedOrder()
331 Assert.True(c.TryTake(out item)); in TryPeek_SucceedsOnEmptyCollectionThatWasOnceNonEmpty()
336 Assert.False(c.TryTake(out item)); in TryPeek_SucceedsOnEmptyCollectionThatWasOnceNonEmpty()
625 Assert.True(c.TryTake(out item)); in TryAdd_TryTake_ToArray()
628 Assert.True(c.TryTake(out item)); in TryAdd_TryTake_ToArray()
677 Assert.Equal(oracle.TryTake(out expected), c.TryTake(out actual)); in ToArray_AddTakeSameThread_ExpectedResultsAfterAddsAndTakes()
[all …]
H A DConcurrentBagTests.cs74 Assert.True(bag.TryTake(out item)); in AddOnOneThread_PeekOnAnother_EnsureWeCanTakeOnTheOriginal()
89 Assert.True(bag.TryTake(out item)); in AddManyItems_ThenTakeOnDifferentThread_ItemsOutputInExpectedOrder()
113 Assert.True(bag.TryTake(out item)); in IterativelyAddOnOneThreadThenTakeOnAnother_OrderMaintained()
173 Assert.True(bag.TryTake(out item)); in ToArray_AddTakeDifferentThreads_ExpectedResultsAfterAddsAndTakes()
192 public bool TryTake(out int item) in TryTake() method in System.Collections.Concurrent.Tests.ConcurrentBagTests.BagOracle
H A DBlockingCollectionTests.cs130 if (m_BlockingQueueUnderTest.TryTake(out item, 1)) in TestBugFix626345()
374 Assert.Throws<ObjectDisposedException>(() => blockingCollection.TryTake(out item)); in Test4_Dispose()
375 Assert.Throws<ObjectDisposedException>(() => blockingCollection.TryTake(out item, 2)); in Test4_Dispose()
376 …Assert.Throws<ObjectDisposedException>(() => blockingCollection.TryTake(out item, new TimeSpan(2))… in Test4_Dispose()
529 Assert.False(blockingCollection.TryTake(out item)); in Test7_CompleteAdding()
875 …Assert.Throws<ArgumentOutOfRangeException>(() => blockingCollection.TryTake(out item, new TimeSpan… in Test18_TakeExceptions()
876 … Assert.Throws<ArgumentOutOfRangeException>(() => blockingCollection.TryTake(out item, -2) ); in Test18_TakeExceptions()
1075 if (blockingCollection.TryTake(out itemFromBlockingCollection)) in AddAnyTakeAny()
1095 concurrentCollection.TryTake(out itemFromConcurrentCollection); in AddAnyTakeAny()
1194 public bool TryTake(out T item) in TryTake() method in System.Collections.Concurrent.Tests.BlockingCollectionTests.ConcurrentStackCollection
H A DBlockingCollectionCancellationTests.cs53 Assert.False(coll1.TryTake(out item)); in InternalCancellation_WakingUp()
77 () => bc.TryTake(out item, 100000, cs.Token), cs.Token, in ExternalCancel_Negative()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/tests/Performance/
H A DPerf.ConcurrentBag.cs61 public void TryTake(bool exists) in TryTake() method in System.Collections.Concurrent.Tests.Perf_ConcurrentBag
80 b.TryTake(out int result); in TryTake()
99 b.TryTake(out int result); in AddTake()
131 b.TryTake(out int result); in Pooling_AddTakeFromSameThreads()
175 if (b.TryTake(out int result)) in ProducerConsumer_AddTakeFromDifferentThreads()
/dports/lang/mono/mono-5.10.1.57/mcs/class/Mono.Parallel/Test/Mono.Collections.Concurrent/
H A DCollectionStressTestHelper.cs66 while (coll.TryTake (out temp)) { in AddStressTest()
95 s &= coll.TryTake (out t); in RemoveStressTest()
97 if (!s && coll.TryTake (out t)) in RemoveStressTest()
110 while (coll.TryTake (out temp)) { in RemoveStressTest()
/dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/Test/System.Collections.Concurrent/
H A DCollectionStressTestHelper.cs66 while (coll.TryTake (out temp)) { in AddStressTest()
95 s &= coll.TryTake (out t); in RemoveStressTest()
97 if (!s && coll.TryTake (out t)) in RemoveStressTest()
110 while (coll.TryTake (out temp)) { in RemoveStressTest()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/src/System/Collections/Concurrent/
H A DBlockingCollection.cs543 if (!TryTake(out item, Timeout.Infinite, CancellationToken.None)) in Take()
567 if (!TryTake(out item, Timeout.Infinite, cancellationToken)) in Take()
585 public bool TryTake(out T item) in TryTake() method in System.Collections.Concurrent.BlockingCollection
587 return TryTake(out item, 0, CancellationToken.None); in TryTake()
607 public bool TryTake(out T item, TimeSpan timeout) in TryTake() method in System.Collections.Concurrent.BlockingCollection
628 public bool TryTake(out T item, int millisecondsTimeout) in TryTake() method in System.Collections.Concurrent.BlockingCollection
653 … public bool TryTake(out T item, int millisecondsTimeout, CancellationToken cancellationToken) in TryTake() method in System.Collections.Concurrent.BlockingCollection
732 removeSucceeded = _collection.TryTake(out item); in TryTakeWithNoTimeValidation()
1356 ….IsCompleted && collections[i]._occupiedNodes.CurrentCount > 0 && collections[i].TryTake(out item)) in TryTakeFromAnyCore()
1450 if (collections[index].TryTake(out item)) //case#1 in TryTakeFromAnyCoreSlow()
H A DIProducerConsumerCollection.cs71 bool TryTake(out T item); in TryTake() method
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/sys/system/collections/concurrent/
H A DBlockingCollection.cs554 if (!TryTake(out item, Timeout.Infinite, CancellationToken.None)) in Take()
578 if (!TryTake(out item, Timeout.Infinite, cancellationToken)) in Take()
596 public bool TryTake(out T item) in TryTake() method in System.Collections.Concurrent.BlockingCollection
598 return TryTake(out item, 0, CancellationToken.None); in TryTake()
618 public bool TryTake(out T item, TimeSpan timeout) in TryTake() method in System.Collections.Concurrent.BlockingCollection
639 public bool TryTake(out T item, int millisecondsTimeout) in TryTake() method in System.Collections.Concurrent.BlockingCollection
664 … public bool TryTake(out T item, int millisecondsTimeout, CancellationToken cancellationToken) in TryTake() method in System.Collections.Concurrent.BlockingCollection
743 removeSucceeded = m_collection.TryTake(out item); in TryTakeWithNoTimeValidation()
1371 …IsCompleted && collections[i].m_occupiedNodes.CurrentCount > 0 && collections[i].TryTake(out item)) in TryTakeFromAnyCore()
1466 if (collections[index].TryTake(out item)) //case#1 in TryTakeFromAnyCoreSlow()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/ref/
H A DSystem.Collections.Concurrent.cs49 public bool TryTake(out T item) { throw null; } in TryTake() method in System.Collections.Concurrent.BlockingCollection
50 public bool TryTake(out T item, int millisecondsTimeout) { throw null; } in TryTake() method in System.Collections.Concurrent.BlockingCollection
51 …public bool TryTake(out T item, int millisecondsTimeout, System.Threading.CancellationToken cancel… in TryTake() method in System.Collections.Concurrent.BlockingCollection
52 public bool TryTake(out T item, System.TimeSpan timeout) { throw null; } in TryTake() method in System.Collections.Concurrent.BlockingCollection
75 public bool TryTake(out T result) { throw null; } in TryTake() method in System.Collections.Concurrent.ConcurrentBag
141 …bool System.Collections.Concurrent.IProducerConsumerCollection<T>.TryTake(out T item) { throw null… in TryTake() method in System.Collections.Concurrent.ConcurrentQueue
163 …bool System.Collections.Concurrent.IProducerConsumerCollection<T>.TryTake(out T item) { throw null… in TryTake() method in System.Collections.Concurrent.ConcurrentStack
183 bool TryTake(out T item); in TryTake() method
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Immutable/src/System/Collections/Immutable/
H A DSecureObjectPool.cs54 public bool TryTake(TCaller caller, out SecurePooledObject<T> item) in TryTake() method in System.Collections.Immutable.TCaller
56 …SecureObjectPool.UnassignedId && AllocFreeConcurrentStack<SecurePooledObject<T>>.TryTake(out item)) in TryTake()
/dports/irc/smuxi/smuxi-1.1/lib/ServiceStack/src/ServiceStack.Common/Net30/
H A DConcurrentQueue.cs36 bool TryTake(out T item); in TryTake() method
214 bool IProducerConsumerCollection<T>.TryTake (out T item) in TryTake() method in ServiceStack.Common.Net30.ConcurrentQueue
/dports/devel/cquery/cquery-20180718/src/
H A Dlru_cache.h25 bool TryTake(const TKey& key, TValue* dest);
102 bool LruCache<TKey, TValue>::TryTake(const TKey& key, TValue* dest) { in TryTake() function
/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/pkg/limiter/
H A Dfixed.go29 func (t Fixed) TryTake() bool { func
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/pkg/limiter/
H A Dfixed.go29 func (t Fixed) TryTake() bool { func
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/pkg/limiter/
H A Dfixed.go29 func (t Fixed) TryTake() bool { func
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/pkg/limiter/
H A Dfixed.go29 func (t Fixed) TryTake() bool { func
/dports/devel/godot-tools/godot-3.2.3-stable/modules/mono/glue/GodotSharp/GodotSharp/Core/
H A DGodotSynchronizationContext.cs18 while (_queue.TryTake(out var workItem)) in ExecutePendingContinuations()
/dports/devel/godot/godot-3.2.3-stable/modules/mono/glue/GodotSharp/GodotSharp/Core/
H A DGodotSynchronizationContext.cs18 while (_queue.TryTake(out var workItem)) in ExecutePendingContinuations()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/mscorlib/system/collections/Concurrent/
H A DIProducerConsumerCollection.cs75 bool TryTake(out T item); in TryTake() method
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Internal/
H A DIProducerConsumerCollection.cs71 bool TryTake(out T item); in TryTake() method

1234