不知道下面这个想法是否可以解决问题:
如果硬件是多核的,可以考虑再把接收消息暂存任务放到一个线程中,处理消息放到另一组线程中(这组线程数不要设置多余硬件cpu核-1),这样就不会有处理线程去干扰接收消息的线程了。
【 在 AlphaO 的大作中提到: 】
: 嗯,已经是分离的架构,类似下面语句不断循环
: if let Ok(size) = bufreader.read(&mut msg, MAX_READ_LENGTH).await {
: mpsc_handle_tx.try_send(msg).unwrap();
: ...................
--
修改:NewMonk FROM 117.133.64.*
FROM 117.133.64.*