搜狗workflow——C++并行计算与异步网络引擎 序列化与反序列化 代码分析（十）
2021SC@SDUSC
目录
这一篇我们进入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