湖州企业做网站,oss 阿里云wordpress,硬之城电子元器件商城,电子商务网站功能需求前言#xff1a;
简单回顾一下上文所学#xff0c;上文我们最重要核心的工作就是介绍了我们线程自己的LWP和tid究竟是个什么#xff0c;总结一句话#xff0c;就是tid是用户视角下所认为的概念#xff0c;因为在Linux系统中#xff0c;从来没有线程这一说法#xff0c;…前言
简单回顾一下上文所学上文我们最重要核心的工作就是介绍了我们线程自己的LWP和tid究竟是个什么总结一句话就是tid是用户视角下所认为的概念因为在Linux系统中从来没有线程这一说法有的就是LWP轻量级进程。正因如此用户和内核所看待的线程是不一样的所以我们就可以认为这个tid就是作为用户所维护的线程而据了解这个tid其实就是在pthread库里面的一个地址这个地址指向是真正维护线程的“线程控制块”的起始地址
线程互斥
抢票现象
临近新年祝大家新年快乐既然是新年就拿枪火车票举个例子下面我将创建5个线程来一起抢火车票这个车票我将定位全局变量作为大家共享的资源。
#include iostream
#include vector
#include string
#include pthread.h
#include unistd.hint tickets 1000;void *Routine(void *args)
{std::string name (const char *)args;while(true){if(tickets 0){usleep(10000);std::cout name got ticket, the rest of: tickets std::endl;tickets--;}elsebreak;}return nullptr;
}int main()
{std::vectorpthread_t threads(5);for (int i 1; i 5; i){char *name new char[128];snprintf(name, 128, thread_%d, i);pthread_create(threads[i], nullptr, Routine, (void *)name);}for (auto t : threads){pthread_join(t, nullptr);}return 0;
}最终5个线程会疯狂进行抢票但是最终我们会发现票数变为了负数
不仅仅会发现票数出现负数就连最终的打印结果也很混乱其实我们之前测试线程所打印出来的数据多多少少都很混乱那么接下来我们就来浅谈出现这些问题的原因。
分析抢票
首先我们需要明确的一点就是tickets是一个共享资源所有线程都可以访问它。
其次就是我们所写的代码将来都是会被翻译为汇编指令的所以我们写的if_else还是tickets–最终都会是一条条汇编语句从C的角度来看可能就一条语句但是真实的汇编可就不只一条而是会和寄存器挂钩出现很多条汇编语句。
if_else的内部逻辑
tickets变量的值将从内存加载到一个寄存器中通常是eax或r0取决于架构。 通过CMP比较指令与常量0进行比较。 根据比较结果利用JMP类指令如JLE、JG等决定跳转到代码的不同部分。 源操作数tickets从内存加载到通用寄存器如eax。 目标操作数0直接用立即数参与比较。
MOV eax, [tickets] ; 将tickets值加载到寄存器eax
CMP eax, 0 ; 比较eax和0
JLE end_loop ; 如果tickets 0跳转到结束tickets–的内部逻辑
对于后置减减的逻辑可以简单理解为我先存储减1之后的结果但是我还是用原来的数据等你这一行代码执行完了我再把结果给还回来。
所以我们可以猜测汇编语句是这么写的
mov eax, [tickets] ; 加载 tickets 的值到寄存器
mov temp, eax ; 保存旧值到 temp
sub eax, 1 ; 递减 eax
mov [tickets], eax ; 将减后的值写回 tickets
mov result, temp ; 返回旧值总结负数原因
如果从底层来看的话还是能很好的说明情况。
假设票数tickets被抢到为1了那么此时假设线程A进来了if语句中它来判断票数是否大于1了那么线程A就会把1放在if语句的寄存器中来进行判断。假设线程A的时间到了CPU会赶走线程A和它的寄存器所以线程A就会带着它在寄存器里存放的1在别的地方呆着同时也会记住自己刚刚所在的代码行然后CPU立马切换线程B来执行线程B同样走到了if语句中把1放在了自己的寄存器中然后一切没问题之后进行减减操作所以票数tickets就变为了0。线程B执行完后轮到线程A了线程A就重新回来同样把寄存器里的值交给寄存器然后去判断发现寄存器里的值是1那么就可以通过if语句。 既然通过了那么后面线程A并不知道票数tickets发生改变了所以线程A执行了减减操作然后票数tickrts就从0变为了-1。 1、线程A判断 tickets 1 时被挂起。 2、线程B修改了 tickets从 1 减到 0。 3、线程A恢复后基于过时的判断执行了递减操作使得 tickets 从 0 变为 -1。 如何解决
造成这种问题的主要原因还是因为多个线程在互相争夺资源所以导致每次访问资源时会出现多个线程。
因此最重要的解决方案无非就是保证任何时刻只允许一个线程进行资源访问也就是互斥。
首先我们需要回顾一下之前在学习信号量那部分时学到的一个专有名词——临界资源。 所谓临界资源就是需要被保护的共享资源。
而对临界资源进行保护本质是对临界区代码进行保护结合上面的例子来看临界资源就是抢票的那个过程我们需要保证一次只能有一个线程进入这就达成了一种保护。 因此为了能达到这个保护措施我们就需要引入pthread库提供的接口 —— 锁。
加锁保护
介绍锁
互斥锁 互斥锁是一种同步机制它允许多个线程在同一时刻最多只有一个线程访问共享资源。 互斥锁的设计是“锁”和“解锁”的机制确保同一时刻只有一个线程能“持有”锁从而保护临界区即共享资源访问的代码块。
pthread_mutex_t 类型 在 Pthreads 中互斥锁是通过 pthread_mutex_t 类型实现的。 一个互斥锁可以被初始化、上锁加锁、解锁以及销毁。
静态初始化
如果定义的是全局的锁可以使用静态的方式初始化这把锁也可以使用动态的方式初始化这把锁。使用静态的方法进行初始化可以不需要destroy
pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER;动态初始化
如果定义的是一把局部的锁则必须用动态的方式初始化这把锁。
#include pthread.hint pthread_mutex_init( /* 初始化成功时返回 0失败时返回错误码 */pthread_mutex_t *restrict mutex, /* 需要初始化的互斥量 (锁) */const pthread_mutexattr_t *restrict attr); /* 互斥量 (锁) 的属性一般设置为 空 即可 */
销毁锁
#include pthread.hint pthread_mutex_destroy( /* 销毁成功时返回 0失败时返回错误码 */pthread_mutex_t *mutex); /* 要销毁的互斥量 (锁) */上锁
#include pthread.hint pthread_mutex_lock( /* 上锁成功时返回 0失败时返回错误码 */pthread_mutex_t *mutex); /* 需要上锁的互斥量 (锁) */解锁
#include pthread.hint pthread_mutex_unlock( /* 解锁成功时返回 0失败时返回错误码 */pthread_mutex_t *mutex); /* 需要解锁的互斥量 (锁) */注意事项 线程就是参与抢票的所以都需要先申请锁 所以线程申请锁前提是所有线程都得看到这把锁锁本身也是共享资源 加锁的过程必须是原子的一会讲 如果线程申请锁失败了代表锁被其它线程拿走了那该线程就要阻塞等待。 如果线程申请锁成功了继续向后运行 如果线程申请锁成功了执行临界区的代码了执行临界区代码期间可以切换但是其他线程依旧无法进入因为锁还未释放。 多线程之间需要竞争锁才能访问临界区这说明了锁本身也是一种临界资源。 既然锁也是临界资源那么就需要被保护起来实际上锁只要保证申请锁的过程是原子的就能保护好自己。一会讲
总结对于所有线程要么我没有申请锁要么我释放了锁这样对其他线程才有意义
何为原子性
—— 要么不做要么做要做就直接做完。 举个例子**上述抢票代码的if_else的判断就不是一个原子操作**因为底层要不断的切换寄存器这就导致了多个线程之间可以在此处发生切换这也是引发竞态条件的主要原因。
改进代码
// 定义并初始化全局锁
pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER;void *Routine(void *args)
{std::string name (const char *)args;while(true){pthread_mutex_lock(mutex); // 上锁// 临界资源if(tickets 0){usleep(10000);std::cout name got ticket, the rest of: tickets std::endl;tickets--;pthread_mutex_unlock(mutex); // 解锁}else{pthread_mutex_unlock(mutex); // 解锁break;}}return nullptr;
}最后很明显也不会再出现抢票抢到负数的情况了。
锁的底层
大多数体系结构都提供了swap或exchange指令,该指令的作用是把寄存器和内存单元的数据相交换,由于只有一条指令,保证了原子性,即使是多处理器平台,访问内存的 总线周期也有先后,一个处理器上的交换指令执行时另一个处理器的交换指令只能等待总线周期。 铺垫一下 1、CPU的寄存器只有一套被所有的线程共享。但是寄存器里面的数据属于执行流的上下文属于执行流私有的数据即独属于线程。
2、CPU在执行代码的时候一定会有对应的执行载体即线程进程
3、数据在内存中被所有线程是共享的。
所以把数据从内存移动到CPU寄存器中本质是把数据从共享变成线程私有
那么我们再从底层原理出发来看 因为我们定义锁肯定是在内存空间上定义的所以我们不妨简单一点我们认为在内存上存在一块空间记录锁的状态 根据提供出来的汇编代码第一步就是将%al寄存器里面初始化个0。然后再与物理内存中的锁进行交换交换完之后%al就变为了1那么这就代表着上锁成功了。 因为交换的过程是原子的这就可以避免出现线程切换从而造成复杂的场面。
就算在%al寄存器与内存交换完后发生线程交换那该线程就会带走%al寄存器里的数据在旁边等着因为该数据是该线程的
切换完后来的那个新线程同样也会先把%al寄存器清0但当他与内存中的锁发生交换后仍然还是0因为锁此时还没被释放
那么新线程就会被判断发现0就会在阻塞等待直到切换到上一个线程然后释放锁了才会再去执行新线程
而释放锁其实也是一种交换那么对于锁的底层实现我们也看到其特有的原子性就能放心的使用锁了因为锁也是一种被保护起来的临界资源。
线程同步
互斥 同步
因为我们两章的内容分别是线程互斥与线程同步但其实我们应该真正介绍下互斥与同步的区别与关系为什么我放在这里来讲而不是开头呢 就是因为互斥比较好理解在学习完线程互斥才能更好的理解线程同步。
「互斥」是为了解决资源分配的问题确保某一时刻只允许一个线程进入执行 「同步」是为了解决执行顺序的问题在互斥的基础上协调线程的执行顺序
互斥解决的是资源竞争问题“不能同时做”。同步解决的是执行顺序问题“必须等待某个条件”。
假设有一天有三个小伙子想去网吧上网但是网吧目前只有一台电脑互斥锁的出现就是能保证每次都只会有一个人进去网吧上网
但是这会造成一种情况一个人可以不断的进网吧和出网吧而其他两个人就只能在旁边看着。这也是线程互斥带了的一个问题
其实最好的解决方法就是让三个小伙子排队等待即
这也是线程同步所解决的执行顺序的问题。
条件变量
在理解线程的「互斥」与「同步」之间的关系之后我们就自然而然的需要来想办法解决「同步」所需要的执行顺序的问题了。
现在我们又需要换一种故事来讲解条件变量 现在我们假设网吧的电脑出现了问题而这时候有一个人一直在疯狂的抢锁然后进去网吧发现电脑故障用不了就出来但是他总觉得自己能修好所以一直在进进出出。 可是网吧老板知道了这件事情后带着新电脑来以旧换新只是网吧老板一直都抢不过这个小伙子老板一直拿不到锁那么老板就一直进不去进不去就无法换新电脑那这个网吧迟早会被这个小伙子干倒闭 所以这个时候老板就会先给网吧贴一个告示代表现在出问题了那么其他用户看到告示后就会跑到别的地方集合等待老板撕下告示这样就代表可以进入玩游戏了这样老板就可以无限不用担心竞争不到锁了
简单来说条件变量就相当于是一个告示为了方便理解所以举了这么个例子但其实每个用户都应当先解锁然后发现电脑坏了然后再跑出来在等待地点这个等待地点就是条件变量进行等待直到老板过来说“可以玩了”这样其他用户才会再次竞争锁然后访问资源。
接口 初始化条件变量 同初始化互斥锁一样初始化条件变量也有静态初始化和动态初始化两种方式。 静态分配 pthread_cond_t cond PTHREAD_COND_INITIALIZER;动态分配 全局的条件变量可以使用 静态 / 动态 的方式初始化。局部的条件变量必须使用 动态 的方式初始化。 #include pthread.hint pthread_cond_init(pthread_cond_t *restrict cond, /* 需要初始化的条件变量 */const pthread_condattr_t *restrict attr); /* 条件变量的属性一般都设置为空 */销毁条件变量 局部的条件变量必须销毁全局的则不用 #include pthread.hint pthread_cond_destroy(pthread_cond_t *cond); // 销毁指定的 cond 条件变量让线程去条件变量下等待 #include pthread.hint pthread_cond_wait( pthread_cond_t *restrict cond, /* 条件变量指定线程需要去 cond 条件变量处等待 */pthread_mutex_t *restrict mutex); /* 互斥锁需要释放当前线程所持有的互斥锁 */哪个线程调用的该函数就让哪个线程去指定的条件变量处等待还要将这个线程持有的锁释放让其他线程能够争夺这把锁。 线程在哪调用的这个函数被唤醒之后就要从这个地方继续向下执行后续代码。 当线程被唤醒之后线程是在临界区被唤醒的线程要重新参与对 mutex 锁的竞争线程被唤醒 重新持有锁两者加起来线程才真正被唤醒。 唤醒在条件变量处等待的线程 唤醒条件变量的方式有 2 种分别是唤醒全部线程以及唤醒首个线程。 #include pthread.hint pthread_cond_broadcast(pthread_cond_t *cond); // 唤醒在 cond 条件变量队列处等待的 所有 线程
int pthread_cond_signal(pthread_cond_t *cond); // 唤醒在 cond 条件变量队列处等待的 首个 线程该函数说是唤醒了线程其实只是一种伪唤醒只有当线程被伪唤醒 重新持有锁才是真唤醒. 只有被真唤醒的线程才会继续去执行后续代码.
代码测试
#include iostream
#include string
#include vector
#include unistd.h
#include pthread.hpthread_mutex_t gmutex PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t gcond PTHREAD_COND_INITIALIZER;void *Routine(void *args)
{std::string name (const char *)args;while (true){pthread_mutex_lock(gmutex);pthread_cond_wait(gcond, gmutex); // 等待被唤醒usleep(10000);std::cout Hi I am name std::endl;pthread_mutex_unlock(gmutex);sleep(1);}return nullptr;
}int main()
{std::vectorpthread_t threads(5);// 创建5个线程for (int i 0; i 5; i){char *buffer new char[1024];snprintf(buffer, 1024, thread-%d, i 1);std::cout create buffer but not to do sometings std::endl;pthread_create(threads[i], nullptr, Routine, (void *)buffer);usleep(10000);}sleep(3);while (true){// 唤醒5个线程一个一个的唤醒pthread_cond_signal(gcond);std::cout 唤醒一个线程 std::endl;sleep(2);}// 等待回收5个线程for (const auto t : threads)pthread_join(t, nullptr);return 0;
}总结
本文我们打通了线程之间的互斥与同步的关系那我们的多线程部分也马上就要结束了我们的Linux操作系统也就到达了尾声阶段接下来我会给大家介绍生产消费者模型并动手实现在实现完后就会引入信号量的概念随后就是手搓一个线程池紧接着我们就会开始我们的Liunx网络篇。
