/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Collections.Concurrent/ |
H A D | ConcurrentBagTests.cs | 65 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 D | CollectionStressTestHelper.cs | 66 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 D | BlockingCollectionTests.cs | 176 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 D | ProducerConsumerCollectionTests.cs | 96 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 D | ConcurrentBagTests.cs | 74 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 D | BlockingCollectionTests.cs | 130 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 D | BlockingCollectionCancellationTests.cs | 53 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 D | Perf.ConcurrentBag.cs | 61 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 D | CollectionStressTestHelper.cs | 66 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 D | CollectionStressTestHelper.cs | 66 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 D | BlockingCollection.cs | 543 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 D | IProducerConsumerCollection.cs | 71 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 D | BlockingCollection.cs | 554 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 D | System.Collections.Concurrent.cs | 49 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 D | SecureObjectPool.cs | 54 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 D | ConcurrentQueue.cs | 36 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 D | lru_cache.h | 25 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 D | fixed.go | 29 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 D | fixed.go | 29 func (t Fixed) TryTake() bool { func
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/pkg/limiter/ |
H A D | fixed.go | 29 func (t Fixed) TryTake() bool { func
|
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/pkg/limiter/ |
H A D | fixed.go | 29 func (t Fixed) TryTake() bool { func
|
/dports/devel/godot-tools/godot-3.2.3-stable/modules/mono/glue/GodotSharp/GodotSharp/Core/ |
H A D | GodotSynchronizationContext.cs | 18 while (_queue.TryTake(out var workItem)) in ExecutePendingContinuations()
|
/dports/devel/godot/godot-3.2.3-stable/modules/mono/glue/GodotSharp/GodotSharp/Core/ |
H A D | GodotSynchronizationContext.cs | 18 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 D | IProducerConsumerCollection.cs | 75 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 D | IProducerConsumerCollection.cs | 71 bool TryTake(out T item); in TryTake() method
|