。

即多个指令输入该服务后对象后#xff0c;Service内部有专门的消费线程执行传入的指令。

每个指令的执行间隔为1秒。

这里有两部分组成#xff0c;

有个Service类自己在内部实现生产者/消费者模式。

即多个指令输入该服务后对象后Service内部有专门的消费线程执行传入的指令。

每个指令的执行间隔为1秒。

这里有两部分组成

Thread与Task.Run。

执行等待的方法。

Thread.Sleep与Task.Delay。

测试环境

BlockingCollectionAction();public

int

AddAction(){_collection.Add(F);}public

void

Thread(Worker_Sleep).Start();}public

void

Thread(Worker_Delay).Start();}public

void

Run3(){Task.Run(Worker_Sleep);}public

void

Run4(){Task.Run(Worker_Delay);}private

void

_collection.GetConsumingEnumerable()){action?.Invoke();Thread.Sleep(DelayMillisecond);}}}private

async

_collection.GetConsumingEnumerable()){action?.Invoke();await

Task.Delay(DelayMillisecond);}}}

}使用BlockingCollection存储指令并通过GetConsumingEnumerable消费。

run1。

ThreadThread.Sleep。

run2。

ThreadTask.Delay。

run3。

Task.RunThread.Sleep。

run4。

Task.RunTask.Delay。

var

{Console.WriteLine(${DateTime.Now.ToString(HH:mm:ss

ffff)}\t{Thread.CurrentThread.ManagedThreadId}\tCount:{Count});

};//

actionInterval);services.Add(s);

}Console.WriteLine(${DateTime.Now.ToString(HH:mm:ss

ffff)}\tRun);

Console.ReadLine();Console.WriteLine(${DateTime.Now.ToString(HH:mm:ss

{for

serviceCount50,100,200,500,1000。

其他使用默认

类型对象个数指令个数间隔完成耗时run150312.3srun1100312.1srun1200312.2srun1500312.4srun11000312.9srun250312.3srun2100312.5srun2200313.1srun2500315.2srun210003110.5srun3503127srun31003178srun320031-run350031-run3100031-run450312.2srun4100312.1srun4200312.2srun4500312.4srun41000312.7s

3个指令1秒间隔理想状态下完成耗时应是2秒。

且随着对象个数增多仍然能保持在一个合理范围。

run1。

ThreadThread.Sleep。

run4。

Task.RunTask.Delay。

服务数量serviceCount2000

Task.RunTask.Delay在初始化阶段需要占用较大的cpu资源。

后续较为平稳对数量的增加并不敏感200到2000ThreadThread.Sleep在初始化期间与正常运行两个周期前后一致性较强。

但是对数量的增加敏感200到2000