C++面向对象多线程学习笔记_同步对象

通常而言,同步变量和条件变量声明为全局,所以,多个线程可以访问它们。虽然这需要使用同步变量的所有线程提供了方便,但它没有提供这些线程遵循的策略。这意味着线程可以按任意方式自由使用(或误用)同步变量。而且,传统同步变量没有为程序员提供实际的方法,将变量与需要同步的数据或设备直接关联。

随着软件工程变得复杂,单个程序中源模块的数量逐渐增加。在大型多线程程序中,同步变量可能在一个源模块中全局声明,程序内的众多源模块都可以访问。跟踪哪一个源模块正锁定或取消锁定哪一个同步变量是一项繁琐而且容易出错的任务。而且,如果同步变量的数量很大,分清哪些变量与哪些数据对应使用变得更困难。

使用面向对象技术去同步化变量。首先,互斥量或条件变量以及所有的相关系统服务都被封闭在一个接口类中。这意味着互斥量对线程内的所有函数或过程不再具有全局性。对互斥量的唯一的访问途径是通过类成员函数。其次,接口类与即将通过继承或复合同步的数据或设备直接关联。

1. Mutext类

class mutex{

protected:

pthread_mutex_t Mutex;

general_exception SemException;

public:

mutex(void){

if(ptrhead_mutex_init(&Mutex, NULL)){

SemException.message("Could Not create Mutex");

throw SemException;

}

~mutex(void);

void lock(void);

void unlock(void);

};

使用mutex类与传统互斥量方法的重要区别在于互斥量类型的对象不会声明为自由漂浮或全局的对象。互斥量类型对象设计用作数据类或设备类的组件。它可以私有性地被一个数据或设备类继承,也可以嵌入另一个使用复合的类中。

mutex用于保护该宿主类具有的所有临界区,该类决定部署互斥量的方式和时间。对象的用户不必担心同步化对象的使用,因为对象同步化自身。同步临界区的责任从对象的用户转而由对象的生产者承担。

1.1 命名互斥量类

命名互斥量可以被同一进程内的线程以及不同进程间的线程共享,而匿名互斥量则只用于执行同一进程中线程间的同步,它不与文件名字关联。在命名互斥量类中,我们可使用互斥量持续时间(mutex duration)作为一种技术来帮助我们避免死锁。

class named_mutex:public mutex{

protected:

char MutexName[81];

int initiallyOwned;

public:

named_mutex(void);

named_mutex(char *MName, int Owned = 0);

unsigned long lockDuration(void);

void lockDuration(unsigned long Dur);

};

1.2 同步和依赖性关系

同步关系相关的控制机制为:互斥量、条件变量与条件断言;依赖性关系相关的控制机制为:线程间通信和进程间通信。

面向对象编程的一个基本概念即类通过方法(method)调控对数据组件的所有访问。

我们的目标是通过面向对象技术管理竞争条件和死锁,同样我们希望将实现并发的责任转移到类、类库以及应用框架级别,减少并发和同步编程的一些复杂性。

1.3 表示条件的类

class event_mutex{

protected:

LPSECURITY_ATTRIBUTES SecurityPtr;

HANDLE EventMutex;

char MutexName[81];

int InitiallySet;

general_exception EventException;

unsigned long EventWait;

unsigned int AccessLevel;

int ManualReset;

public:

event_mutex(char *MName, unsigned int Initial = 0, unsigned long Reset,

LPSECURITY_ATTRUBUTES Secure){

EventMutex = CreateEvent(Secure, Reset, Initial, Mname);

if(!EventMutex){

EventException.message("Could not create Event Semaphore");

throw EventException;

}

if(MName !=NULL){

strcpy(MutextName, MName);

}

EventWait = INFINITE;

}

event_mutex(char *MName, unsigned int Access, unsigned long Inherit){

EventMutex = OpenEvent(Access, Inherit, MName);

if(!EventMutex){

EventException.message("Could not create Event Semaphore");

throw EventException;

}

if(MName != NULL){

strcpy(MutexName, Mname);

}

EventWait = INFINITE;

}

void postEvent(void){

SetEvent(EventMutex);

}

void waitEvent(void){

WaitForSingleObject(EventMutex, EventWait);

}

void resetEvent(void){

ResetEvent(EventMutex);

}

~event_mutex(void){

if(!CloseHandle(EventMutex)){

EventException.message("Could not close mutex");

throw EventException;

}

}

};

其中使用多构造函数的模式使得客户/服务器多进程处理更方便,它避免程序员必须编写重复代码之劳。

1.4 等待多个事件或互斥量

另一种类型的条件变量就是包含多个事件或互斥量的事件互斥量(event mutex)。阻塞于这些多个等待变量的线程的线程可能等待所有事件,在处理过程继续之前,互斥量根据这些事件来设置。

class multiple_event_mutex{

protected:

char MutexName[81];

SEMRECORD *ConditionList;

int EventNumber;

long int WaitSelection;

HEV EventMutex;

MultipleEventMutex;

general_exception EventException;

int Duration;

public:

multiple_event_mutex(char *MName, int ENum, long int WaitType, int Initial){

int N;

EventNumber = ENum;

ConditionList = new SEMRECORD[ENum];

for(N = 0; N < ENum; ++N){

if(DosCreateEventSem(NULL, &EventMutex, 0, Imitial)){

EventException.message("Could not create event semaphore");

throw EventException;

}

ConditionList[N].hsemCur = &EventMutex;

ConditionList[N].ulUser = N;

}

if(DosCreateMuxWaitSem(MName, &MultipleEventMutex, sizeof(ConditionList), ConditionList, WaitType)){

EventException.message("Could not create multiple event semaphore.");

throw EventException;

}

}

multiple_event_mutex(char *MName){

if(DosOpenMuxWaitSem(MName, &MultipleEventMutex)){

EventException.message("Could not open event semaphore");

throw EventException;

}

}

~multiple_event_mutex(void){

if(DosCloseMuxWaitSem(MultipleEventMutex)){

EventException.message("Could not close event semaphore");

throw EventException;

}

delete ConditionList;

}

int duration(int x){

return Duration;

}

void duration(int x){

Duration = X;

}

void postEvent(int x){

EventMutex = (HEV) ConditionList[x].hsemCur;

DosPostEventSem(EventMutex);

}

void waitEvents(void){

unsigned long user;

DosWaitMuxWaitSem(MultipleEventMutex, SEM_INDEFINITE_WAIT, &User);

}

};

针对复杂事务处理,有一套标准可以衡量特定事务是否让数据库处于一致的状态。其中一个标准就是ACID测试。缩写ACID代表原子性(atomicity)、一致性(consistency),孤立性(isolation)以及持久性(durability)。

};

1.5 小结

同步对象可以通过设计封装了系统API的接口类(Inteface class)来创建。一旦创建了同步类(synchronization class),在那些被多线程或多进程并发或同步使用的任何类型C++类中,可以添加以上同步类。在某个类中包含同步类或者使用复合、包容或继承来实现。建议只让类中的直接成员访问同步类,只有在非常特定的条件下才允许同步类被派生类访问。

在try块中放入声明对象的优点在于,抛出异常时自动调用它们的析构函数。应该用面向对象技术来关联同步机制与即将同步的对象或设备,也就是说在任何可能的地方,避免自由漂浮的同步对象。使用类聚集(class aggregation)来连接同步类(synchronization class)与数据(data class)和设备类(device class)。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,504评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,434评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,089评论 0 349
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,378评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,472评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,506评论 1 292
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,519评论 3 413
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,292评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,738评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,022评论 2 329
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,194评论 1 342
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,873评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,536评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,162评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,413评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,075评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,080评论 2 352

推荐阅读更多精彩内容

  • 接着上上节 thread ,本节主要介绍mutex的内容,练习代码地址。<mutex>:该头文件主要声明了与互斥量...
    jorion阅读 12,482评论 2 4
  • 接着上节 atomic,本节主要介绍condition_varible的内容,练习代码地址。本文参考http://...
    jorion阅读 8,479评论 0 7
  • 引用自多线程编程指南应用程序里面多个线程的存在引发了多个执行线程安全访问资源的潜在问题。两个线程同时修改同一资源有...
    Mitchell阅读 1,987评论 1 7
  • 教程一:视频截图(Tutorial 01: Making Screencaps) 首先我们需要了解视频文件的一些基...
    90后的思维阅读 4,686评论 0 3
  • 线程基础 线程是进程的一个执行单元,执行一段程序片段,线程共享全局变量;线程的查看可以使用命令或者文件来进行查看;...
    秋风弄影阅读 737评论 0 0