求好手关于Thread Manager的设计

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

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

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

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

大家有没有什么好办法和主意？有UML图之类的设计，高分求！
[解决办法]

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


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

lock();
DataCollection.read();
unLock();

....

lock();
DataCollection.write();
unLock();

[解决办法]
可不可以写个适配器来适配DataCollection的接口呢！！在适配器里加锁
[解决办法]
共享循环队列+Mutex互斥+条件变量等待。

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

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

看你的线程分工与数量，自己选择合适的方法。
[解决办法]
可以自己再封装一层(和4楼意思差不多)

//示意代码
class DataCollectionForThreadSafe
{
public:
        write()
        {
             lock();
             dataCollection->write();
             unlock();
        }
        read()
        {
             lock();
             dataCollection->read();
             unlock();
         }
private:
       DataCollection* dataCollection;
}

引用:

现在就是这么设计的，但是代码很恶心啊，所有的地方都要加lock() and unlock()，如果以后忘加了就挂掉了，有没有什么方法可以强制写，例如楼上说的接口之类的方法，但是我现在想不出，才求助！

引用:
思路因该是这样的：如果DataCollection内部不能加锁， 那就在调用它的地方加锁

C/C++ code

lock();
Dat……

[解决办法]
外面调用的人只用DataCollectionForThreadSafe， 不用DataCollection。
或者说用户根本不需要知道DataCollection的存在

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

比如：

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;
}

查看更多 下一篇