| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Linq.Parallel/src/System/Linq/Parallel/Scheduling/ |
| H A D | CancellationState.cs | 47 internal CancellationState(CancellationToken externalCancellationToken) in CancellationState() argument
49 ExternalCancellationToken = externalCancellationToken; in CancellationState()
82 …nternal static void ThrowWithStandardMessageIfCanceled(CancellationToken externalCancellationToken) in ThrowWithStandardMessageIfCanceled() argument
84 if (externalCancellationToken.IsCancellationRequested) in ThrowWithStandardMessageIfCanceled()
87 throw new OperationCanceledException(oceMessage, externalCancellationToken); in ThrowWithStandardMessageIfCanceled()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/Scheduling/ |
| H A D | CancellationState.cs | 53 internal CancellationState(CancellationToken externalCancellationToken) in CancellationState() argument
55 ExternalCancellationToken = externalCancellationToken; in CancellationState()
88 …nternal static void ThrowWithStandardMessageIfCanceled(CancellationToken externalCancellationToken) in ThrowWithStandardMessageIfCanceled() argument
90 if (externalCancellationToken.IsCancellationRequested) in ThrowWithStandardMessageIfCanceled()
93 throw new OperationCanceledException(oceMessage, externalCancellationToken); in ThrowWithStandardMessageIfCanceled()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/src/System/Collections/Concurrent/ |
| H A D | BlockingCollection.cs | 979 …ion<T>[] collections, T item, int millisecondsTimeout, CancellationToken externalCancellationToken) in TryAddToAnyCore() argument
1007 …List<WaitHandle> handles = GetHandles(collections, externalCancellationToken, true, out collatedCa… in TryAddToAnyCore()
1029 if (externalCancellationToken.IsCancellationRequested) //case#3 in TryAddToAnyCore()
1030 … throw new OperationCanceledException(SR.Common_OperationCanceled, externalCancellationToken); in TryAddToAnyCore()
1091 tokensList.Add(externalCancellationToken); in GetHandles()
1348 …T item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) in TryTakeFromAnyCore() argument
1361 …nyCoreSlow(collections, out item, millisecondsTimeout, isTakeOperation, externalCancellationToken); in TryTakeFromAnyCore()
1382 …T item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) in TryTakeFromAnyCoreSlow() argument
1412 …List<WaitHandle> handles = GetHandles(collections, externalCancellationToken, false, out collatedC… in TryTakeFromAnyCoreSlow()
1427 …if (linkedTokenSource.IsCancellationRequested && externalCancellationToken.IsCancellationRequested… in TryTakeFromAnyCoreSlow()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/sys/system/collections/concurrent/ |
| H A D | BlockingCollection.cs | 990 …ion<T>[] collections, T item, int millisecondsTimeout, CancellationToken externalCancellationToken) in TryAddToAnyCore() argument
1018 …List<WaitHandle> handles = GetHandles(collections, externalCancellationToken, true, out collatedCa… in TryAddToAnyCore()
1040 if (externalCancellationToken.IsCancellationRequested) //case#3 in TryAddToAnyCore()
1041 …w OperationCanceledException(SR.GetString(SR.Common_OperationCanceled), externalCancellationToken); in TryAddToAnyCore()
1103 tokensList.Add(externalCancellationToken); in GetHandles()
1362 …T item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) in TryTakeFromAnyCore() argument
1376 …CoreSlow(collections, out item, millisecondsTimeout, isTakeOperation, externalCancellationToken); in TryTakeFromAnyCore()
1397 …T item, int millisecondsTimeout, bool isTakeOperation, CancellationToken externalCancellationToken) in TryTakeFromAnyCoreSlow() argument
1428 …List<WaitHandle> handles = GetHandles(collections, externalCancellationToken, false, out collatedC… in TryTakeFromAnyCoreSlow()
1443 …if (linkedTokenSource.IsCancellationRequested && externalCancellationToken.IsCancellationRequested… in TryTakeFromAnyCoreSlow()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Core/System/Linq/Parallel/QueryOperators/ |
| H A D | QuerySettings.cs | 90 CancellationToken externalCancellationToken, ParallelExecutionMode? executionMode, in QuerySettings()
95 m_cancellationState = new CancellationState(externalCancellationToken); in QuerySettings()
135 …CancellationToken externalCancellationToken = (this.CancellationState.ExternalCancellationToken.Ca… in Merge()
139 … return new QuerySettings(tm, dop, externalCancellationToken, executionMode, mergeOptions); in Merge()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Linq.Parallel/src/System/Linq/Parallel/QueryOperators/ |
| H A D | QuerySettings.cs | 84 CancellationToken externalCancellationToken, ParallelExecutionMode? executionMode, in QuerySettings()
89 _cancellationState = new CancellationState(externalCancellationToken); in QuerySettings()
129 …CancellationToken externalCancellationToken = (this.CancellationState.ExternalCancellationToken.Ca… in Merge()
133 … return new QuerySettings(tm, dop, externalCancellationToken, executionMode, mergeOptions); in Merge()
|