一个单线程改成多线程的问题

ailure

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

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

yulihua49

ailure 发表于 2014-04-24 14:46
最近考虑把现在的程序改成多线程, 初步构想是这样的:
上图是现在的系统架构,下图是目标架构,共4个工作 ...

MQ是否允许多线程同时MQ_get();
如果不允许，就一个线程MQ_get，把结果加入分发队列。
工作线程用条件变量取分发队列。

ailure

多谢回复.
当前的想法是允许多个线程MQ_get(), 这儿必须要加锁吧？
如果用分发队列的话, 是不是每个线程有一个MessageQue, 主线程读取消息后以简单的round robin机制拷贝到
各个线程的MessageQue, 但这时也需要加锁吗?否则工作线程和主线程会发生读写冲突吗？ 或者简单的主线程从队在队列头写，工作线程在队尾读， 这个应该有现成的无锁队列的实现吧？如果不需要锁的话，应该能提高并发性。
另外，如果工作线程要发消息呢？是不是也是同样的实现？

Dannysd

一读一写情况下的无锁队列

这个真没找到现成的（同求）

也可以考虑环形队列吧

ailure

单个线程内的无锁队列应该有很多实现吧？
你是不是指多线程共享的无锁队列？