Commit c371f008 authored by Savorboard's avatar Savorboard

modify queue processor count with option config.

parent 52ec7934
...@@ -49,7 +49,7 @@ namespace DotNetCore.CAP.Processor ...@@ -49,7 +49,7 @@ namespace DotNetCore.CAP.Processor
try try
{ {
var worked = await Step(context); var worked = await Step(context);
context.ThrowIfStopping(); context.ThrowIfStopping();
Waiting = true; Waiting = true;
......
...@@ -39,8 +39,9 @@ namespace DotNetCore.CAP.Processor ...@@ -39,8 +39,9 @@ namespace DotNetCore.CAP.Processor
public void Start() public void Start()
{ {
var processorCount = Environment.ProcessorCount; var processorCount = _options.QueueProcessorCount;
_processors = GetProcessors(processorCount); _processors = GetProcessors(processorCount);
_logger.ServerStarting(processorCount, _processors.Length); _logger.ServerStarting(processorCount, _processors.Length);
_context = new ProcessingContext(_provider, _cts.Token); _context = new ProcessingContext(_provider, _cts.Token);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment