Use Threadpool for pipe scheduler (#1497)
This commit is contained in:
parent
b60e4cfea6
commit
8594d2b897
|
|
@ -514,8 +514,8 @@ namespace Microsoft.AspNetCore.Sockets
|
||||||
|
|
||||||
private DefaultConnectionContext CreateConnectionInternal(HttpSocketOptions options)
|
private DefaultConnectionContext CreateConnectionInternal(HttpSocketOptions options)
|
||||||
{
|
{
|
||||||
var transportPipeOptions = new PipeOptions(pauseWriterThreshold: options.TransportMaxBufferSize, resumeWriterThreshold: options.TransportMaxBufferSize / 2);
|
var transportPipeOptions = new PipeOptions(pauseWriterThreshold: options.TransportMaxBufferSize, resumeWriterThreshold: options.TransportMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool);
|
||||||
var appPipeOptions = new PipeOptions(pauseWriterThreshold: options.ApplicationMaxBufferSize, resumeWriterThreshold: options.ApplicationMaxBufferSize / 2);
|
var appPipeOptions = new PipeOptions(pauseWriterThreshold: options.ApplicationMaxBufferSize, resumeWriterThreshold: options.ApplicationMaxBufferSize / 2, readerScheduler: PipeScheduler.ThreadPool);
|
||||||
return _manager.CreateConnection(transportPipeOptions, appPipeOptions);
|
return _manager.CreateConnection(transportPipeOptions, appPipeOptions);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue