读书人

求高手关于Thread Manager的设计,该如

发布时间: 2012-03-28 15:40:03 作者: rapoo

求高手关于Thread Manager的设计
最近手上一个项目非常棘手,需要用到多线程,多线程中的数据保护成为一个大难题,
因此想在这与大家讨论一下,如何设计一个Thread Manager去控制一个线程,并保护线程所要提供的数据

举个例子
我们有一个主线程,Main Thread, 其中正在做数据的采集,
其中有一个对象DataCollection, 里面有Vector, Int,和 MyObject 数据变量 等等

另外有一个线程,从并口接受数据,并进行分析,从DataCollection里面取数据,比如存取Vector 的值,MyObject的值,
这样操作可能会带来潜在危险。

按常理,我们可以通过在DataCollection里加锁,Mutex来解决,可是,假设对象DataCollection 是线程不安全,并不可以做大的修改。
如何设计一个Thread Manager 或者 是一个接口函数,或者是一个Wrapper,去管理这个线程
让其做到:
1. 控制线程的运行,停止等等
2. 防止线程安全

大家有没有什么好办法和主意?有UML图之类的设计,高分求!

[解决办法]

标记,正在写线程池实现。


[解决办法]
思路因该是这样的:如果DataCollection内部不能加锁, 那就在调用它的地方加锁

C/C++ code
lock();DataCollection.read();unLock();....lock();DataCollection.write();unLock();
[解决办法]
可不可以写个适配器来适配DataCollection的接口呢!!在适配器里加锁
[解决办法]
共享循环队列+Mutex互斥+条件变量等待。

或者做事件型异步设计,利用管道+I/O复用+循环队列+Mutex。

或者做成I/O IPC问题,一端写管道,一端读管道,也是很安全的。

看你的线程分工与数量,自己选择合适的方法。
[解决办法]
可以自己再封装一层(和4楼意思差不多)
C/C++ code
//示意代码class DataCollectionForThreadSafe{public:        write()        {             lock();             dataCollection->write();             unlock();        }        read()        {             lock();             dataCollection->read();             unlock();         }private:       DataCollection* dataCollection;}
[解决办法]
外面调用的人只用DataCollectionForThreadSafe, 不用DataCollection。
或者说用户根本不需要知道DataCollection的存在

把DataCollection中的接口都在DataCollectionForThreadSafe中实现

比如:
C/C++ code
class DataCollection{public:    //会读取或者修改数据的接口    TypeReturn1 fun1(Type1 Para1, Type2 para2 ){....}    //不会读取或者修改数据的接口    TypeReturn2 fun2(Type3 Para3, Type4 para4 ){....}。。。。。。}......class DataCollectionForThreadSafe{public:        //会读取或者修改数据的接口        TypeReturn1 fun1(Type1 Para1, Type2 para2 )        {                lock();                dataCollection->fun1(Para1, para2);                unlock        }        //不会读取或者修改数据的接口        TypeReturn2 fun2(Type3 Para3, Type4 para4 )        {                dataCollection->fun2(Para3, para4 );        }。。。。。。private:        DataCollection* dataCollection;}
[解决办法]
用的时候这么用

比如在某个类中:
C/C++ code
//以前class MyClass{    void useDataCollection(Type1 para1, Type2 para2 ) {dataCollection->fun1(para1, para2);}private:     DataCollection * dataCollection; }//现在可以变成class MyClass{    void useDataCollection(Type1 para1, Type2 para2 ) {dataCollection->fun1(para1, para2);}private:     DataCollectionForThreadSafe* dataCollection; }
[解决办法]
我想你可以去看一下设计模式中的 —— 适配器模式, 这应该对你有帮助

读书人网 >C++

热点推荐