[C++知识库]搜狗workflow——C++并行计算与异步网络引擎 序列化与反序列化 代码分析（十）

2021SC@SDUSC

目录

一.前置知识

1.头文件

二.代码分析部分

这一篇我们进入client.c的代码分析。这一章先介绍client.c的前置内容部分，主要的main方法我们放在下一篇文章来讲。

一.前置知识

1.<mutex>头文件

mutex 头文件中主要包含 Mutexes、lock 和相关的类型(Other types)和公共函数。

其中mutexes的相关类中，提供了几种锁对象：

一是mutex互斥锁是一个可锁的对象，它被设计成在关键的代码段需要独占访问时发出信号，从而阻止具有相同保护的其他线程并发执行并访问相同的内存位置；

二是recursive_mutex,一个递归互斥锁。递归互斥锁是一个可锁的对象，就像互斥一样，但是允许同一个线程获得对互斥对象的多个级别的所有权。

三是timed_mutex,定时的互斥信号是一个时间可锁定的对象,旨在当关键部分的代码需要独占访问时,就像一个普通互斥,但另外支持定时try-lock请求。

四是recursive_timed_mutex，结合了递归互斥和定时的优点，特点是recursive_mutex timed_mutex到单个类的特性:它同时支持由一个线程获取多个锁级别也定时try-lock请求。

还有std::mutex,不允许拷贝；互斥对象不能被复制/移动，初始状态为未锁定;lock,锁住互斥对象等。

Locks 模板类：

如lock_guard模板类，锁保护是一个通过将互斥对象保持锁定来管理互斥对象的对象。

unique_lock模板类unique_lock与 lock_guard 类相似，但它提供了更好的上锁和解锁控制。

其它的成员函数如：

1.lock ,上锁和解锁的过程是Lock mutex (public member function )，作用是调用被托管的互斥对象的成员锁；

2.unlock，上锁和解锁的过程是Unlock mutex (public member function )，作用是解锁。

3.swap，修改方式是Swap unique locks (public member function )，作用是交换两个互斥对象。

4.release，修改方式是Release mutex (public member function )，作用是释放锁。

二.代码分析部分

#include <string.h>

#include <stdio.h>

#include <mutex>

#include <condition_variable>

#include "workflow/Workflow.h"

#include "workflow/WFTaskFactory.h"

#include "message.h"

//这里引进的类里面有一个<mutex>头文件，主要包含 Mutexes、lock 和相关的类型(Other types)和公共函数。

using WFTutorialTask = WFNetworkTask<protocol::TutorialRequest,

protocol::TutorialResponse>;

using tutorial_callback_t = std::function<void (WFTutorialTask *)>;

using namespace protocol;

//using的作用我们前几篇文件中学过，是定义别名。在这里，

WFNetworkTask<protocol::TutorialRequest,protocol::TutorialResponse>可以用WFTutorialTask来表示； std::function<void (WFTutorialTask *)>可以用tutorial_callback_t来表示。

class MyFactory : public WFTaskFactory

{

public:

static WFTutorialTask *create_tutorial_task(const std::string& host,

unsigned short port,

int retry_max,

tutorial_callback_t callback)

//创建网络任务

{

using NTF = WFNetworkTaskFactory<TutorialRequest, TutorialResponse>;

WFTutorialTask *task = NTF::create_client_task(TT_TCP, host, port,

retry_max,

std::move(callback));

task->set_keep_alive(30 * 1000);

return task;

//WFNetworkTaskFactory<TutorialRequest,
TutorialResponse>类是用来创建client任务。

}

};

---------------------------------------------------------------------------------------------------------------------------------参考文献：

tutorial/tutorial-10-user_defined_protocol/client.cc · 搜狗开源/workflow - Gitee.com

c++11 多线程（2）mutex 总结 - 简书 (jianshu.com)