ThreadPool

src\Servers\Kestrel\shared\test\RevocationResponder.cs (3)

72ThreadPool.QueueUserWorkItem( 98ThreadPool.QueueUserWorkItem( 119ThreadPool.QueueUserWorkItem(

TestTransport\InMemoryTransportConnection.cs (1)

73ThreadPool.UnsafeQueueUserWorkItem(state =>

DefaultConnectionContext.cs (1)

101ThreadPool.UnsafeQueueUserWorkItem(cts => ((CancellationTokenSource)cts!).Cancel(), _connectionClosedTokenSource);

Internal\HttpConnectionContext.cs (4)

215ThreadPool.UnsafeQueueUserWorkItem(cts => ((CancellationTokenSource)cts!).Cancel(), _connectionClosedTokenSource); 360ThreadPool.UnsafeQueueUserWorkItem(cts => ((CancellationTokenSource)cts!).Cancel(), _connectionClosedTokenSource); 370ThreadPool.UnsafeQueueUserWorkItem(cts => ((CancellationTokenSource)cts!).Cancel(), _connectionClosedTokenSource); 694ThreadPool.UnsafeQueueUserWorkItem(static cts => ((CancellationTokenSource)cts!).Cancel(), _connectionCloseRequested);

HttpContextAccessorTests.cs (4)

42ThreadPool.QueueUserWorkItem(async _ => 87ThreadPool.QueueUserWorkItem(async _ => 133ThreadPool.QueueUserWorkItem(_ => 160ThreadPool.UnsafeQueueUserWorkItem(_ =>

MessagePump.cs (3)

120ThreadPool.UnsafeQueueUserWorkItem(state => state.ActivateRequestProcessingLimits(), this, preferLocal: false); 169ThreadPool.UnsafeQueueUserWorkItem(loop, preferLocal: false); 291ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false);

Core\IISHttpContext.IO.cs (1)

262ThreadPool.UnsafeQueueUserWorkItem(ctx =>

Core\IISHttpServer.cs (1)

167ThreadPool.UnsafeQueueUserWorkItem(context, preferLocal: false);

Core\IO\AsyncIOOperation.cs (1)

154ThreadPool.UnsafeQueueUserWorkItem(Continuation, State, preferLocal: false);

Internal\ConnectionDispatcher.cs (2)

29ThreadPool.UnsafeQueueUserWorkItem(StartAcceptingConnectionsCore, listener, preferLocal: false); 68ThreadPool.UnsafeQueueUserWorkItem(kestrelConnection, preferLocal: false);

Internal\Http2\Http2Connection.cs (1)

1267ThreadPool.UnsafeQueueUserWorkItem(_currentHeadersStream, preferLocal: false);

Internal\Http3\Http3Connection.cs (3)

404ThreadPool.UnsafeQueueUserWorkItem(controlStream, preferLocal: false); 411ThreadPool.UnsafeQueueUserWorkItem(controlStream, preferLocal: false); 600ThreadPool.UnsafeQueueUserWorkItem(stream, preferLocal: false);

Internal\Http3\Http3Stream.cs (1)

871ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false);

src\Servers\Kestrel\shared\test\RevocationResponder.cs (3)

72ThreadPool.QueueUserWorkItem( 98ThreadPool.QueueUserWorkItem( 119ThreadPool.QueueUserWorkItem(

src\Servers\Kestrel\Transport.Sockets\src\Internal\IOQueue.cs (1)

24System.Threading.ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false);

Internal\QuicConnectionContext.cs (1)

137ThreadPool.UnsafeQueueUserWorkItem(state =>

Internal\IOQueue.cs (1)

24System.Threading.ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false);

Internal\SocketAwaitableEventArgs.cs (1)

78ThreadPool.UnsafeQueueUserWorkItem(continuation, state, preferLocal: true);

Internal\SocketConnection.cs (1)

355ThreadPool.UnsafeQueueUserWorkItem(state =>

ObjectMethodExecutorTest.cs (1)

597ThreadPool.QueueUserWorkItem(_ =>

HubConnectionContext.cs (1)

490ThreadPool.QueueUserWorkItem(_abortedCallback, this);

HttpContextBuilder.cs (1)

161ThreadPool.UnsafeQueueUserWorkItem(_ =>

AwaitExtensions.cs (1)

116callbackHandles[i] = ThreadPool.RegisterWaitForSingleObject(

ThreadPoolExtensions.cs (1)

22bool success = ThreadPool.QueueUserWorkItem(

Construction\ProjectRootElement_Tests.cs (4)

1039ThreadPool.QueueUserWorkItem(delegate 1062ThreadPool.QueueUserWorkItem(delegate 1110ThreadPool.QueueUserWorkItem(delegate 1132ThreadPool.QueueUserWorkItem(delegate

BackEnd\BuildManager_Tests.cs (6)

3072ThreadPool.QueueUserWorkItem(delegate 3083ThreadPool.QueueUserWorkItem(delegate 3150ThreadPool.QueueUserWorkItem(delegate 3163ThreadPool.QueueUserWorkItem(delegate 3237ThreadPool.QueueUserWorkItem(delegate 3250ThreadPool.QueueUserWorkItem(delegate

GetSDKReferenceFiles.cs (1)

684ThreadPool.QueueUserWorkItem(sdkFilesCache.SaveAssemblyListToCacheFile, saveContext);

Internal\DefaultHybridCache.StampedeStateT.cs (1)

44ThreadPool.UnsafeQueueUserWorkItem(this, false);

MemoryCache.cs (1)

483ThreadPool.QueueUserWorkItem(s => ((MemoryCache)s!).OvercapacityCompaction(), this);

ServiceLookup\DynamicServiceProviderEngine.cs (1)

34_ = ThreadPool.UnsafeQueueUserWorkItem(_ =>

ThreadPoolExtensions.cs (1)

22bool success = ThreadPool.QueueUserWorkItem(

src\libraries\shims\mscorlib\ref\mscorlib.cs (1)

1176[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.ThreadPool))]

netstandard.cs (1)

2139[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.ThreadPool))]

src\Microsoft.DotNet.Wpf\src\Shared\MS\Internal\SafeSecurityHelper.cs (1)

447ThreadPool.QueueUserWorkItem(callback, state);

MS\Internal\Data\DefaultAsyncDataDispatcher.cs (1)

34ThreadPool.QueueUserWorkItem(new WaitCallback(ProcessRequest), request);

System\Windows\Data\ObjectDataProvider.cs (1)

304ThreadPool.QueueUserWorkItem(new WaitCallback(QueryWorker), null);

System\Windows\Data\XmlDataProvider.cs (3)

313ThreadPool.QueueUserWorkItem(new WaitCallback(BuildNodeCollectionAsynch), 380ThreadPool.QueueUserWorkItem(new WaitCallback(CreateDocFromExternalSourceAsynch), 427ThreadPool.QueueUserWorkItem(new WaitCallback(CreateDocFromInlineXmlAsync),

MS\Internal\Documents\DocumentSignatureManager.cs (1)

1052System.Threading.ThreadPool.QueueUserWorkItem(new WaitCallback(CertificateStatusCheckWorkItem), threadInfo);

MS\Internal\Documents\RightsManagementManager.cs (1)

372if (ThreadPool.QueueUserWorkItem(new WaitCallback(RMEnrollThreadProc), rmEnrollThreadInfo))

Common\System\Data\ProviderBase\DbConnectionPool.cs (1)

1051ThreadPool.QueueUserWorkItem(_poolCreateRequest);

System\Diagnostics\AsyncStreamReader.cs (1)

249ThreadPool.QueueUserWorkItem(edi => ((ExceptionDispatchInfo)edi!).Throw(), ExceptionDispatchInfo.Capture(e));

System\Diagnostics\Process.Unix.cs (1)

185_registeredWaitHandle = ThreadPool.RegisterWaitForSingleObject(_waitHandle,

System\IO\Pipelines\ThreadPoolScheduler.netcoreapp.cs (2)

13System.Threading.ThreadPool.QueueUserWorkItem(action, state, preferLocal: false); 18System.Threading.ThreadPool.UnsafeQueueUserWorkItem(action, state, preferLocal: false);

System\IO\Ports\SerialStream.Unix.cs (3)

744ThreadPool.QueueUserWorkItem(s => { 755ThreadPool.QueueUserWorkItem(s => { 766ThreadPool.QueueUserWorkItem(s => {

System\Net\Managed\ListenerAsyncResult.Managed.cs (2)

77ThreadPool.UnsafeQueueUserWorkItem(s_invokeCB, this); 182ThreadPool.UnsafeQueueUserWorkItem(s_invokeCB, this);

System\Net\Sockets\SocketAsyncContext.Unix.cs (2)

264ThreadPool.UnsafeQueueUserWorkItem(o => ((AsyncOperation)o!).InvokeCallback(allowPooling: false), this); 288ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false);

System\Net\Sockets\SocketAsyncEngine.Unix.cs (2)

211ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false); 245ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false);

src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (1)

168ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: true);

src\libraries\System.Private.CoreLib\src\System\Diagnostics\Tracing\RuntimeEventSource.cs (3)

107_threadPoolThreadCounter ??= new PollingCounter("threadpool-thread-count", this, () => ThreadPool.ThreadCount) { DisplayName = "ThreadPool Thread Count" }; 109_threadPoolQueueCounter ??= new PollingCounter("threadpool-queue-length", this, () => ThreadPool.PendingWorkItemCount) { DisplayName = "ThreadPool Queue Length" }; 110_completedItemsCounter ??= new IncrementingPollingCounter("threadpool-completed-items-count", this, () => ThreadPool.CompletedWorkItemCount) { DisplayName = "ThreadPool Completed Work Item Count", DisplayRateTimeScale = new TimeSpan(0, 0, 1) };

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ConfiguredValueTaskAwaitable.cs (2)

105Unsafe.As<IValueTaskSource>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token, 210Unsafe.As<IValueTaskSource<TResult>>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token,

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ValueTaskAwaiter.cs (2)

97Unsafe.As<IValueTaskSource>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext); 179Unsafe.As<IValueTaskSource<TResult>>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext);

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\YieldAwaitable.cs (3)

100ThreadPool.QueueUserWorkItem(s_waitCallbackRunAction, continuation); 104ThreadPool.UnsafeQueueUserWorkItem(s_waitCallbackRunAction, continuation); 139ThreadPool.UnsafeQueueUserWorkItemInternal(box, preferLocal: false);

src\libraries\System.Private.CoreLib\src\System\Runtime\InteropServices\PosixSignalRegistration.Unix.cs (1)

115ThreadPool.UnsafeQueueUserWorkItem(HandleSignal, (signo, tokens));

src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.cs (1)

35private static readonly bool s_initialized = ThreadPool.EnsureConfigInitialized();

src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.GateThread.cs (1)

99if (ThreadPool.EnableWorkerTracking && NativeRuntimeEventSource.Log.IsEnabled())

src\libraries\System.Private.CoreLib\src\System\Threading\PortableThreadPool.WaitThread.cs (1)

386ThreadPool.UnsafeQueueHighPriorityWorkItemInternal(

src\libraries\System.Private.CoreLib\src\System\Threading\RegisteredWaitHandle.Portable.cs (1)

11/// An object representing the registration of a <see cref="WaitHandle"/> via <see cref="ThreadPool.RegisterWaitForSingleObject"/>.

src\libraries\System.Private.CoreLib\src\System\Threading\RegisteredWaitHandle.Unix.cs (1)

11/// An object representing the registration of a <see cref="WaitHandle"/> via <see cref="ThreadPool.RegisterWaitForSingleObject"/>.

src\libraries\System.Private.CoreLib\src\System\Threading\SynchronizationContext.cs (1)

25=> ThreadPool.QueueUserWorkItem(static s => s.Key(s.Value), new KeyValuePair<SendOrPostCallback, object?>(d, state), preferLocal: false);

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ConcurrentExclusiveSchedulerPair.cs (2)

209ThreadPool.QueueUserWorkItem(static state => 351ThreadPool.UnsafeQueueUserWorkItemInternal(workItem, preferLocal: !fairly);

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\FutureFactory.cs (1)

680ThreadPool.RegisterWaitForSingleObject(

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\ManualResetValueTaskSourceCore.cs (4)

186ThreadPool.UnsafeQueueUserWorkItem(continuation, state, preferLocal: true); 190ThreadPool.QueueUserWorkItem(continuation, state, preferLocal: true); 231ThreadPool.UnsafeQueueUserWorkItem(continuation, _continuationState, preferLocal: true); 332ThreadPool.QueueUserWorkItem(continuation, continuationState, preferLocal: true);

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (8)

1926ThreadPool.QueueUserWorkItem(static state => ((ExceptionDispatchInfo)state!).Throw(), edi); 2591ThreadPool.UnsafeQueueUserWorkItemInternal(stateMachineBox, preferLocal: true); 3066bool notifyWhenUnblocked = ThreadPool.NotifyThreadBlocked(); 3075ThreadPool.NotifyThreadUnblocked(); 3084bool notifyWhenUnblocked = ThreadPool.NotifyThreadBlocked(); 3093ThreadPool.NotifyThreadUnblocked(); 3591ThreadPool.UnsafeQueueUserWorkItemInternal(new CompletionActionInvoker(completionAction, this), preferLocal: true); 7393ThreadPool.UnsafeQueueUserWorkItem(static state =>

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskContinuation.cs (3)

584ThreadPool.UnsafeQueueUserWorkItemInternal(this, preferLocal: true); 786ThreadPool.UnsafeQueueUserWorkItemInternal(box, preferLocal: true); 821ThreadPool.UnsafeQueueUserWorkItemInternal(atc, preferLocal: true);

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ThreadPoolTaskScheduler.cs (5)

57ThreadPool.UnsafeQueueUserWorkItemInternal(task, (options & TaskCreationOptions.PreferFairness) == 0); 72if (taskWasPreviouslyQueued && !ThreadPool.TryPopCustomWorkItem(task)) 91return ThreadPool.TryPopCustomWorkItem(task); 96return FilterTasksFromWorkItems(ThreadPool.GetQueuedWorkItems()); 115ThreadPool.NotifyWorkItemProgress();

src\libraries\System.Private.CoreLib\src\System\Threading\Thread.cs (3)

402_name = ThreadPool.WorkerThreadName; 403ThreadNameChanged(ThreadPool.WorkerThreadName); 430if (_name != ThreadPool.WorkerThreadName)

src\libraries\System.Private.CoreLib\src\System\Threading\ThreadPoolWorkQueue.cs (14)

600ThreadPool.RequestWorkerThread(); 820ThreadPoolWorkQueue workQueue = ThreadPool.s_workQueue; 864ThreadPool.RequestWorkerThread(); 922ThreadPool.RequestWorkerThread(); 941ThreadPool.RequestWorkerThread(); 1014if (ThreadPool.EnableWorkerTracking) 1039if (!ThreadPool.NotifyWorkItemComplete(threadLocalCompletionCountObject!, currentTickCount)) 1061if (ThreadPool.YieldFromDispatchLoop) 1092Debug.Assert(ThreadPool.EnableWorkerTracking); 1098ThreadPool.ReportThreadStatus(isWorking: true); 1105ThreadPool.ReportThreadStatus(isWorking: false); 1146threadLocalCompletionCountObject = ThreadPool.GetOrCreateThreadLocalCompletionCountObject(); 1216ThreadPool.UnsafeQueueHighPriorityWorkItemInternal(this); 1244ThreadPool.UnsafeQueueHighPriorityWorkItemInternal(this);

src\libraries\System.Private.CoreLib\src\System\Threading\Timer.cs (1)

265ThreadPool.UnsafeQueueUserWorkItemInternal(timer, preferLocal: false);

src\libraries\System.Private.CoreLib\src\System\Threading\TimerQueue.Portable.cs (1)

128ThreadPool.UnsafeQueueHighPriorityWorkItemInternal(timerToFire);

Internals\System\Runtime\IOThreadScheduler.cs (1)

532ThreadPool.UnsafeQueueNativeOverlapped(_nativeOverlapped);

System\Threading\Channels\AsyncOperation.netcoreapp.cs (3)

11ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false); 14ThreadPool.UnsafeQueueUserWorkItem(action, state, preferLocal: false); 17ThreadPool.QueueUserWorkItem(action, state, preferLocal: false);

Internal\Common.cs (1)

303ThreadPool.QueueUserWorkItem(static state => { ((ExceptionDispatchInfo)state!).Throw(); }, edi);

System\Threading\Tasks\Parallel.ForEachAsync.cs (1)

600ThreadPool.UnsafeQueueUserWorkItem(this, preferLocal: false);

artifacts\obj\System.Threading.ThreadPool\Debug\net9.0\System.Threading.ThreadPool.Forwards.cs (1)

5[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.ThreadPool))]

System\Transactions\TransactionState.cs (2)

2838if (!ThreadPool.QueueUserWorkItem(SignalMethod, tx)) 3949if (!ThreadPool.QueueUserWorkItem(SignalMethod, tx))

System\Transactions\VolatileEnlistmentMultiplexing.cs (4)

95if (!ThreadPool.QueueUserWorkItem(PrepareCallback, demux)) 134if (!ThreadPool.QueueUserWorkItem(CommitCallback, demux)) 173if (!ThreadPool.QueueUserWorkItem(RollbackCallback, demux)) 212if (!ThreadPool.QueueUserWorkItem(InDoubtCallback, demux))

src\Microsoft.DotNet.Wpf\src\Shared\MS\Internal\SafeSecurityHelper.cs (1)

447ThreadPool.QueueUserWorkItem(callback, state);