免费创建个人商城网站,东莞建设最好的镇,网站后台管理系统设计,上海企业网上公示系统场景
有个Service类#xff0c;自己在内部实现生产者/消费者模式。即多个指令输入该服务后对象后#xff0c;Service内部有专门的消费线程执行传入的指令。每个指令的执行间隔为1秒。这里有两部分组成#xff0c;
工作线程的载体。new Thread与Task.Run。执行等待的方法。…场景
有个Service类自己在内部实现生产者/消费者模式。即多个指令输入该服务后对象后Service内部有专门的消费线程执行传入的指令。每个指令的执行间隔为1秒。这里有两部分组成
工作线程的载体。new Thread与Task.Run。执行等待的方法。Thread.Sleep与Task.Delay。
测试环境
cpu: AMD 3700x 8核16线程 RAM128G 3200MHz
示例代码
public class Service
{public Service(int id, Action f, int delayMillisecond 1000){Id id;F f;DelayMillisecond delayMillisecond;}private int DelayMillisecond;private BlockingCollectionAction _collection new BlockingCollectionAction();public int Id { get; }public Action F { get; }public void AddAction(){_collection.Add(F);}public void Run1(){new Thread(Worker_Sleep).Start();}public void Run2(){new Thread(Worker_Delay).Start();}public void Run3(){Task.Run(Worker_Sleep);}public void Run4(){Task.Run(Worker_Delay);}private void Worker_Sleep(){{foreach (var action in _collection.GetConsumingEnumerable()){action?.Invoke();Thread.Sleep(DelayMillisecond);}}}private async void Worker_Delay(){{foreach (var action in _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 serviceCount 200; // 服务数量
var actionCount 3; // 指令个数
var actionInterval 1000; // 指令执行时间间隔ms
var services new ListService();Action f ()
{Console.WriteLine(${DateTime.Now.ToString(HH:mm:ss ffff)}\t{Thread.CurrentThread.ManagedThreadId}\tCount:{Count});
};// 生成所有服务对象
for (int i 0; i serviceCount; i)
{var s new Service(i, f, actionInterval);services.Add(s);
}Console.WriteLine(${DateTime.Now.ToString(HH:mm:ss ffff)}\tRun);
services.ForEach(s s.Run2());while (true)
{// 输入任意内容启动var msg Console.ReadLine();Console.WriteLine(${DateTime.Now.ToString(HH:mm:ss ffff)}\tStart!!!!!!!!!!);// 每个服务对象自行输入指令services.ForEach(s {for (int i 0; i actionCount; i){s.AddAction();}});
}测试参数组为 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和run4是在时间消耗上比较符合期望。
run1。ThreadThread.Sleep。run4。Task.RunTask.Delay。
我们更改参数比较两者的cpu占用情况。测试参数如下 服务数量serviceCount2000 指令个数actionCount50 指令执行时间间隔/msactionInterval 1000 cpu占用情况如图。
服务数量serviceCount200 指令个数actionCount50 指令执行时间间隔/msactionInterval 1000 cpu占用情况如图。 基于这两张图可以得到初步结论
Task.RunTask.Delay在初始化阶段需要占用较大的cpu资源。后续较为平稳对数量的增加并不敏感200到2000ThreadThread.Sleep在初始化期间与正常运行两个周期前后一致性较强。但是对数量的增加敏感200到2000
