ThreadPool

32 references to ThreadPool

ClientSample (2)

Tcp\TcpConnection.cs (2)

32_sender = new SocketSender(_socket, PipeScheduler.ThreadPool); 33_receiver = new SocketReceiver(_socket, PipeScheduler.ThreadPool);

InMemory.FunctionalTests (5)

Http2\Http2TestBase.cs (2)

455var inputPipeOptions = GetInputPipeOptions(_serviceContext, _memoryPool, PipeScheduler.ThreadPool); 456var outputPipeOptions = GetOutputPipeOptions(_serviceContext, _memoryPool, PipeScheduler.ThreadPool);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1119var inputOptions = Http3InMemory.GetInputPipeOptions(_testBase._serviceContext, _testBase._memoryPool, PipeScheduler.ThreadPool); 1120var outputOptions = Http3InMemory.GetOutputPipeOptions(_testBase._serviceContext, _testBase._memoryPool, PipeScheduler.ThreadPool);

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

54Scheduler = PipeScheduler.ThreadPool;

Microsoft.AspNetCore.Http.Connections (2)

HttpConnectionDispatcherOptions.cs (2)

140internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false); 142internal PipeOptions AppPipeOptions => _appPipeOptions ??= new PipeOptions(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);

Microsoft.AspNetCore.Http.Connections.Client (4)

HttpConnectionOptions.cs (2)

125internal PipeOptions TransportPipeOptions => _transportPipeOptions ??= new PipeOptions(pauseWriterThreshold: TransportMaxBufferSize, resumeWriterThreshold: TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false); 127internal PipeOptions AppPipeOptions => _appPipeOptions ??= new PipeOptions(pauseWriterThreshold: ApplicationMaxBufferSize, resumeWriterThreshold: ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);

Internal\ClientPipeOptions.cs (2)

10public static PipeOptions DefaultOptions = new PipeOptions(writerScheduler: PipeScheduler.ThreadPool, readerScheduler: PipeScheduler.ThreadPool, useSynchronizationContext: false);

Microsoft.AspNetCore.Server.IIS (1)

Core\IISHttpContext.cs (1)

493_bodyInputPipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.ThreadPool, minimumSegmentSize: MinAllocBufferSize));

Microsoft.AspNetCore.Server.Kestrel.Core (3)

Internal\Http2\Http2OutputProducer.cs (1)

762writerScheduler: PipeScheduler.ThreadPool,

Internal\Http3\Http3OutputProducer.cs (1)

466writerScheduler: PipeScheduler.ThreadPool,

Internal\KestrelServerImpl.cs (1)

98Scheduler = PipeScheduler.ThreadPool,

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

54Scheduler = PipeScheduler.ThreadPool;

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (3)

SchedulerBenchmark.cs (1)

48_threadPoolSchedulers[i] = PipeScheduler.ThreadPool;

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (2)

Internal\NamedPipeConnectionListener.cs (2)

57_inputOptions = new PipeOptions(_memoryPool, PipeScheduler.ThreadPool, PipeScheduler.Inline, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false); 58_outputOptions = new PipeOptions(_memoryPool, PipeScheduler.Inline, PipeScheduler.ThreadPool, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false);

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (2)

Internal\QuicStreamContext.cs (2)

60var inputOptions = new PipeOptions(MemoryPool, PipeScheduler.ThreadPool, PipeScheduler.Inline, maxReadBufferSize, maxReadBufferSize / 2, useSynchronizationContext: false); 61var outputOptions = new PipeOptions(MemoryPool, PipeScheduler.Inline, PipeScheduler.ThreadPool, maxWriteBufferSize, maxWriteBufferSize / 2, useSynchronizationContext: false);

Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (3)

Client\SocketConnectionFactory.cs (1)

37var applicationScheduler = _options.UnsafePreferInlineScheduling ? PipeScheduler.Inline : PipeScheduler.ThreadPool;

SocketConnectionContextFactory.cs (2)

42var applicationScheduler = options.UnsafePreferInlineScheduling ? PipeScheduler.Inline : PipeScheduler.ThreadPool; 66var transportScheduler = options.UnsafePreferInlineScheduling ? PipeScheduler.Inline : PipeScheduler.ThreadPool;

Sockets.BindTests (1)

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

54Scheduler = PipeScheduler.ThreadPool;

Sockets.FunctionalTests (1)

src\Servers\Kestrel\shared\test\TestServiceContext.cs (1)

54Scheduler = PipeScheduler.ThreadPool;

System.IO.Pipelines (2)

System\IO\Pipelines\PipeOptions.cs (2)

81ReaderScheduler = readerScheduler ?? PipeScheduler.ThreadPool; 82WriterScheduler = writerScheduler ?? PipeScheduler.ThreadPool;