一个多线程的问题

ailure

最近考虑把现在的程序改成多线程, 初步构想是这样的:
上图是现在的系统架构,下图是目标架构,共4个工作线程.
目前的系统就是Process A 收到从Process B到消息, 在接收message que中, 处理消息,然后将回复发送到发送message que中.
多线程大概的思路是这样的:
4个工作线程分别到接收message que取消息, 处理消息,
处理结束后,如果需要发送回复,则发消息到发送message que中,否则接着取消息.

请大家指教, 哪些地方需要改进,或者是需要重点关注的地方,非常感谢!

timespace

实际场景一概不知，这个架构看不出任何问题，当然也就没什么要关注的地方了。

ailure

实际的场景是, 单线程情况下, 因为消息的编解码造成CPU的load很高, message que中的消息经常出现拥塞的情况,所以想到利用多核多线程,提高吞吐量.

timespace

OK，已经明白问题焦点。几个想法：
1. 如果message que的get/put都是线程安全的。问题就比较简单了，处理逻辑和原来一致，仅仅是启用多个线程。
2. 如果message que的get/put不是线程安全的，你可以修改。请把它改为线程安全的，然后继续#1。
3. 如果message que的get/put不是线程安全的，你无法修改。要用两个agent线程中转消息，比如：
    workers <--- recv agent <-- recv Message Queue
    workers ---> send agent --> send Message Queue
每个方向的（recv/send）agent与workers用一个共享队列就行了，先别搞什么负载调度之类的事情，让问题变简单。

linux_c_py_php

这不是很普通的设计么。。

ailure

因该是2: 如果message que的get/put不是线程安全的，你可以修改。请把它改为线程安全的，然后继续#1
还有,你觉得有必每个work thread设一个message que, 然后让主线程将收到的message que分发到各个work thread.
多谢!

ailure

回复 5# linux_c_py_php

您有什么好的建议,多谢!