pthread多线程

pthread库是linux系统的多线程库。上次写完longjmp和多线程的例子。就想用系统的真线程库改写一下读写线程的例子来和大家分享。真线程库应该比自己写的功能更完善,代码也更容易写吧!… …

说到这里。我不知道接下来说什么了… …。也许是自己对多线程库掌握不够熟练吧!代码早就改好了。但是运行多数时候是好的,有的时候却会crash。我确信这是同步的问题。查了好多天。除了费解还是费解。都怀疑到天气热,我的机器内存数据发生突变了。直到刚才改了一处,才稳定了。目前没发现再crash。这就把代码分享上来。这次被这bug整的代码已经有些过度保守了,不像是我自己的风格,但仍不敢保证没有错误了。万一谁在调试中发现新的错误。淡定,在这基础上改。

现在的数据结构变成这样:

typedef struct _Context_ {pthread_mutex_t sched;volatile int wait_thread_lock_sched;int finish;struct {pthread_mutex_t mutex;volatile int wait_sched_lock_thread;int pend;int state;} thread[2];
} Context;#define  WRITE_THREAD 0
#define  READ_THREAD 1

这里用mutex做同步。mutex适合做互斥。在同一线程中上锁,解锁,互斥保护共享资源访问。而理论上是可以做同步的,做同步需要在不同线程中上锁,解锁,实际用下来感觉不理想。

使用pthread线程库时,要注意先测试一下。这一步不能省。我的版本,文档说明说的是没有attr说明的mutex默认创建为普通锁。这可不一定。测试下来发现给的是递归锁。区别在于锁定一个已经锁定mutex,如果上次是自己锁的,普通锁会休眠,而递归锁会成功。

普通用法,在同一线程中对资源上锁,解锁,操作时串行的,不会发生自己两次锁同一个资源问题,这时两者的作用是相同的,除非发生了操作中用了递归函数。可能是因为这个原因,我的系统中默认给了递归锁。

但是同步的用法,上锁和解锁在2个不同的线程中,系统调度是随机的。有可能上锁的线程被调度了2次,而解锁一次也没调度。这样,如果递归锁,它每次上锁都是成功的,它不停下了,它还要继续上锁。这就发生了复杂的问题了。

回到这里的代码,一个调度和2个线程。mutex设置的是普通锁。注意系统的调度仍然在跑,这里意思是自己写的同步的调度,以下简称调度,意思都是自己做的调度。如果线程自己的mutex被别的线程上锁,那么线程运行到这个位置的时候,再次上锁就会休眠,而别的线程解锁,也就唤醒了这个休眠的线程。这样就有了同步的效果。注意休眠线醒来之后已经获得了mutex上锁,它可能需要立即解锁,以便别的线程继续控制锁。

初始化:

        pthread_mutexattr_t mat;pthread_mutexattr_init(&mat);pthread_mutexattr_settype(&mat, PTHREAD_MUTEX_NORMAL);pthread_mutex_init(&bx_mutex, &mat);pthread_mutex_init(&gCtx.sched, &mat);pthread_mutex_init(&gCtx.thread[0].mutex, &mat);pthread_mutex_init(&gCtx.thread[1].mutex, &mat);mutex_lock(&gCtx.thread[0].mutex);mutex_lock(&gCtx.thread[1].mutex);start_coroutine((pf) coroutine_write, NULL);start_coroutine((pf) coroutine_read, NULL);

start_coroutine之后,读写线程有可能已经跑起来了,有可能还没跑,这不一定。之前调度程序已经给它们mutex上了锁,跑起来之后,首先是去对自己的mutex上锁,这样可以进入休眠,让调度程序有序唤醒它们进行操作。

void coroutine_write(void *arg)
{FILE *fp;char s[128];int len;int i = (int) arg;i = WRITE_THREAD;gCtx.thread[i].wait_sched_lock_thread = 999;mutex_lock(&gCtx.thread[i].mutex);mutex_unlock(&gCtx.thread[i].mutex);lock_scheduler();while (gCtx.thread[i].wait_sched_lock_thread != 0) {sched_yield();}fp = fopen("b.c", "r");if (!fp) {printf("can not open `b.c'\n");exit(0);}mutex_lock(&bx_mutex);while (fgets(s, 128, fp) != NULL) {len = strlen(s);if (len) {--len;if (s[len] == '\n') s[len] = '\0'; else ++len;}if (len) {--len;if (s[len] == '\r') s[len] = '\0'; else ++len;}bx_write(s, len + 1);}bx.eobf = 1;gCtx.thread[WRITE_THREAD].state = 1;fclose(fp);
printf("[WRITE_THREAD FINISHED]\n");
report();yield(WRITE_THREAD);
}
void coroutine_read(void *arg)
{char buf[128];int i = (int) arg;i = READ_THREAD;gCtx.thread[i].wait_sched_lock_thread = 999;mutex_lock(&gCtx.thread[i].mutex);mutex_unlock(&gCtx.thread[i].mutex);lock_scheduler();while (gCtx.thread[i].wait_sched_lock_thread != 0) {sched_yield();}mutex_lock(&bx_mutex);while (!bx.eobf || bx.bc) {bx_read(buf, 128);printf("%s\n", buf);}gCtx.thread[READ_THREAD].state = 1;
printf("[READ_THREAD FINISHED]\n");
report();yield(READ_THREAD);
}

线程被调度程序唤醒之后,立即用lock_scheduler()对调度程序的mutex上锁,让调度程序完成调度语义之后可以在这个锁上休眠,等候被调线程完成操作后重新唤醒它。


void lock_scheduler()
{mutex_lock(&gCtx.sched);gCtx.wait_thread_lock_sched = 0;
}

调度程序用resume()唤醒读写线程,之一。唤醒之后跟读写线程交换mutex锁定。最后,调度程序的mutex被读写线程锁定,读写线程的mutex被调度程序锁定:

void resume(int th)
{int i = 0;gCtx.wait_thread_lock_sched = 1;gCtx.thread[th].wait_sched_lock_thread = 1;mutex_unlock(&gCtx.thread[th].mutex);while (gCtx.wait_thread_lock_sched != 0) {sched_yield();}i = 0;mutex_lock(&gCtx.thread[th].mutex);gCtx.thread[th].wait_sched_lock_thread = 0;
}

读写线程做完操作之后,用yield()唤醒调度,同步之后在上了锁的mutex休眠。奇怪的第一句是防止读写线程运行得太快。唤醒之后工作做完了,又一次进入yield,而调度程序上次reume的最后一个同步语句还没有完成。这是有可能发生的。只要OS切换这个调度程序之后,一直不给它CPU,调度程序的动作就会一直被搁置。

void yield(int th)
{int i = 0;if (gCtx.thread[th].wait_sched_lock_thread != 0 ) {gCtx.thread[th].pend++;do {sched_yield();} while(gCtx.thread[th].wait_sched_lock_thread != 0);}mutex_unlock(&bx_mutex);//printf("thread %d yield\n", th);mutex_unlock(&gCtx.sched);gCtx.thread[th].wait_sched_lock_thread = -1;mutex_lock(&gCtx.thread[th].mutex);mutex_unlock(&gCtx.thread[th].mutex);gCtx.thread[th].wait_sched_lock_thread = 0;
}
int main()
{int i;pthread_mutexattr_t mat;pthread_mutexattr_init(&mat);pthread_mutexattr_settype(&mat, PTHREAD_MUTEX_NORMAL);pthread_mutex_init(&bx_mutex, &mat);pthread_mutex_init(&gCtx.sched, &mat);pthread_mutex_init(&gCtx.thread[0].mutex, &mat);pthread_mutex_init(&gCtx.thread[1].mutex, &mat);mutex_lock(&gCtx.thread[0].mutex);mutex_lock(&gCtx.thread[1].mutex);start_coroutine((pf) coroutine_write, NULL);start_coroutine((pf) coroutine_read, NULL);sched_yield();while (gCtx.thread[0].wait_sched_lock_thread == 0) {sched_yield();}gCtx.thread[0].wait_sched_lock_thread = 0;while (gCtx.thread[1].wait_sched_lock_thread == 0) {sched_yield();}gCtx.thread[1].wait_sched_lock_thread = 0;run = 1;while (TRUE) {resched:i = sched();if (gCtx.thread[i].state == 0) {resume(i);mutex_lock(&gCtx.sched);mutex_unlock(&gCtx.sched);} else break;}printf("done\n");return 0;
}

现在看起来已经很严谨了。好像已经可以正常运行了。但是不是哦。多线程变成常会遇到各种意想不到的情况。到了这一步,后来就发生了莫名其妙的crash,但不是每次都错。然后是连续不断的调试。直至怀疑系统lib有bug,甚至是不是自己的机器“热坏了”。好在现在调好了,不用怀疑最后这两条了。

最后贴上完整代码,感兴趣的可以自己试下。不保证一定没有错误哦!

#include <stdio.h>
#include <string.h>
#include <setjmp.h>
#include <stdlib.h>
#include <pthread.h>int mutex_lock(pthread_mutex_t * mutex)
{return pthread_mutex_lock(mutex);
}int mutex_unlock(pthread_mutex_t * mutex)
{return pthread_mutex_unlock(mutex);
}typedef int BOOL;
#define TRUE    1
#define FALSE   0extern pthread_mutex_t bx_mutex;typedef struct _Context_ {pthread_mutex_t sched;volatile int wait_thread_lock_sched;int finish;struct {pthread_mutex_t mutex;volatile int wait_sched_lock_thread;int pend;int state;} thread[2];
} Context;#define  WRITE_THREAD 0
#define  READ_THREAD 1Context gCtx;
static int next_thread;
int run;void report()
{printf("thread 0: locksync %d, pend %d, state %d\n",gCtx.thread[0].  wait_sched_lock_thread,gCtx.thread[0].  pend,gCtx.thread[0].  state);printf("thread 1: locksync %d, pend %d, state %d\n",gCtx.thread[1].  wait_sched_lock_thread,gCtx.thread[1].  pend,gCtx.thread[1].  state);
}
void resume(int th)
{int i = 0;gCtx.wait_thread_lock_sched = 1;gCtx.thread[th].wait_sched_lock_thread = 1;mutex_unlock(&gCtx.thread[th].mutex);while (gCtx.wait_thread_lock_sched != 0) {sched_yield();}i = 0;mutex_lock(&gCtx.thread[th].mutex);gCtx.thread[th].wait_sched_lock_thread = 0;
}void lock_scheduler()
{mutex_lock(&gCtx.sched);gCtx.wait_thread_lock_sched = 0;
}void yield(int th)
{int i = 0;if (gCtx.thread[th].wait_sched_lock_thread != 0 ) {gCtx.thread[th].pend++;do {sched_yield();} while(gCtx.thread[th].wait_sched_lock_thread != 0);}mutex_unlock(&bx_mutex);//printf("thread %d yield\n", th);mutex_unlock(&gCtx.sched);gCtx.thread[th].wait_sched_lock_thread = -1;mutex_lock(&gCtx.thread[th].mutex);mutex_unlock(&gCtx.thread[th].mutex);gCtx.thread[th].wait_sched_lock_thread = 0;
}#define MAXBUFS 10
struct buffer {char buf[MAXBUFS][128];int pos;int bc;int eobf;
};
struct buffer bx;
pthread_mutex_t bx_mutex;void bx_read(char *s, int n)
{restart:if (bx.bc) {if (!(bx.pos >= 0 && bx.pos < MAXBUFS)) {printf("error\n");exit(0);}strncpy(s, bx.buf[bx.pos], n);s[n - 1] = '\0';bx.bc--;bx.pos++;if (bx.pos >= MAXBUFS)bx.pos = 0;return;} else if (bx.eobf) {gCtx.finish = 1;gCtx.thread[run].state = 1;yield(READ_THREAD);} else {yield(READ_THREAD);lock_scheduler();mutex_lock(&bx_mutex);goto restart;}
}void bx_write(char *s, int n)
{int wpos;while (bx.bc >= MAXBUFS) {yield(WRITE_THREAD);lock_scheduler();mutex_lock(&bx_mutex);}wpos = bx.pos + bx.bc;if (wpos >= MAXBUFS)wpos -= MAXBUFS;if (!(wpos >= 0 && wpos < MAXBUFS)) {printf("error\n");exit(0);}if (n < 128) {strcpy(bx.buf[wpos], s);}else {strncpy(bx.buf[wpos], s, 128);bx.buf[wpos][127] = '\0';}bx.bc++;
}typedef void *(*pf) (void *);
BOOL start_coroutine(pf func, void *arg);
void coroutine_read(void *arg);void coroutine_write(void *arg)
{FILE *fp;char s[128];int len;int i = (int) arg;i = WRITE_THREAD;gCtx.thread[i].wait_sched_lock_thread = 999;mutex_lock(&gCtx.thread[i].mutex);mutex_unlock(&gCtx.thread[i].mutex);lock_scheduler();while (gCtx.thread[i].wait_sched_lock_thread != 0) {sched_yield();}fp = fopen("b.c", "r");if (!fp) {printf("can not open `b.c'\n");exit(0);}mutex_lock(&bx_mutex);while (fgets(s, 128, fp) != NULL) {len = strlen(s);if (len) {--len;if (s[len] == '\n') s[len] = '\0'; else ++len;}if (len) {--len;if (s[len] == '\r') s[len] = '\0'; else ++len;}bx_write(s, len + 1);}bx.eobf = 1;gCtx.thread[WRITE_THREAD].state = 1;fclose(fp);
printf("[WRITE_THREAD FINISHED]\n");
report();yield(WRITE_THREAD);
}void coroutine_read(void *arg)
{char buf[128];int i = (int) arg;i = READ_THREAD;gCtx.thread[i].wait_sched_lock_thread = 999;mutex_lock(&gCtx.thread[i].mutex);mutex_unlock(&gCtx.thread[i].mutex);lock_scheduler();while (gCtx.thread[i].wait_sched_lock_thread != 0) {sched_yield();}mutex_lock(&bx_mutex);while (!bx.eobf || bx.bc) {bx_read(buf, 128);printf("%s\n", buf);}gCtx.thread[READ_THREAD].state = 1;
printf("[READ_THREAD FINISHED]\n");
report();yield(READ_THREAD);
}BOOL start_coroutine(pf func, void *arg)
{int thread_id;pthread_t pt_id;thread_id = next_thread++;pthread_create(&pt_id, NULL, func, (void *) thread_id);pthread_detach(pt_id);return TRUE;
}int sched()
{int s;if (run == 0) s = 1; else s = 0;if (gCtx.thread[s].state == 0) run = s;return run;
}int main()
{int i;pthread_mutexattr_t mat;pthread_mutexattr_init(&mat);pthread_mutexattr_settype(&mat, PTHREAD_MUTEX_NORMAL);pthread_mutex_init(&bx_mutex, &mat);pthread_mutex_init(&gCtx.sched, &mat);pthread_mutex_init(&gCtx.thread[0].mutex, &mat);pthread_mutex_init(&gCtx.thread[1].mutex, &mat);mutex_lock(&gCtx.thread[0].mutex);mutex_lock(&gCtx.thread[1].mutex);start_coroutine((pf) coroutine_write, NULL);start_coroutine((pf) coroutine_read, NULL);sched_yield();while (gCtx.thread[0].wait_sched_lock_thread == 0) {sched_yield();}gCtx.thread[0].wait_sched_lock_thread = 0;while (gCtx.thread[1].wait_sched_lock_thread == 0) {sched_yield();}gCtx.thread[1].wait_sched_lock_thread = 0;run = 1;while (TRUE) {resched:i = sched();if (gCtx.thread[i].state == 0) {resume(i);mutex_lock(&gCtx.sched);mutex_unlock(&gCtx.sched);} else break;}printf("done\n");return 0;
}

最后的代码里多出了 一个bx_mutex锁。用来保护bx缓冲区。程序实在调不出来才被逼加上了。但是加上了还是没用!现在如果去掉又要好复杂的调试,已经没有心情去做了。

最后解释一下,究竟出了什么bug,这么难搞。后来又是改在哪里好起来的。供大家参考。缓冲区bx_write上来有这一句:

        int wpos;while (bx.bc >= MAXBUFS) {yield(WRITE_THREAD);lock_scheduler();mutex_lock(&bx_mutex);}

while 原来写的是if。查我的前文可以看到对比。为什么这么改?linux内核编程中有告诫,睡眠进程被唤醒之后,需要重新检查它等待的条件,不能直接认为它等待的条件已经成立。如果不成立,需要重新进入睡眠。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/876854.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ConstraintLayout实现原理分析

ConstraintLayout 是 Android 支持库中提供的一个非常强大的布局管理器&#xff0c;它允许开发者创建复杂的界面布局&#xff0c;并提供了比传统布局更多的灵活性。在 ConstraintLayout 中&#xff0c;视图之间可以通过约束来定义其位置关系&#xff0c;从而使得布局更加动态和…

Python+selenium web自动化测试知识点合集2

选择元素 对于百度搜索页面&#xff0c;如果我们想自动化输入“selenium”&#xff0c;怎么做呢&#xff1f; 这就是在网页中&#xff0c;操控界面元素。 web界面自动化&#xff0c;要操控元素&#xff0c;首先需要 选择 界面元素 &#xff0c;或者说 定位 界面元素 就是 先…

OD C卷 - 电脑病毒感染

电脑病毒感染 &#xff08;200&#xff09; 一个局域网内有n台电脑&#xff0c;编号为 1 -> n&#xff0c;电脑之间病毒感染时间用 t 表示&#xff1b;现在网络内已有一台电脑被病毒感染&#xff0c;求其感染所有其他电脑最少的时间&#xff0c;若最后有电脑不会被感染&…

URL重写

目录 步骤1 规则语法 Nginx URL重写规则语法 Apache URL重写规则语法 步骤2 规则配置 Apache URL重写规则配置 启用mod_rewrite模块 配置.htaccess文件 编写重写规则 测试重写规则 Nginx URL重写规则配置 配置server或location块 测试重写规则 步骤1 规则语法 Ngin…

如何使用Redis实现一个缓存策略

使用Redis实现一个缓存策略&#xff0c;主要涉及到数据的存储、读取、更新以及失效处理等方面。下面我将详细介绍如何使用Redis来设计和实现一个基本的缓存策略。 1. 确定缓存的数据结构和键命名规则 首先&#xff0c;你需要决定使用Redis中的哪种数据结构来存储缓存数据&…

解决在from pyhdf.SD import SD,SDC时No module named “hdfext“

文章内容仅用于自己知识学习和分享&#xff0c;如有侵权&#xff0c;还请联系并删除 &#xff1a;&#xff09; 1. 错误原因&#xff1a; 参考了多个博主的解决办法&#xff0c;结合自己的尝试&#xff0c;发现造成这个问题的主要原因是numpy版本太高 2. 解决方法 方法1&…

Day.31 | 1049.最后一块石头的重量II 494.目标和 474.一和零

1049.最后一块石头的重量II 要点&#xff1a;思路与分割等和子集很类似&#xff0c;把总数分成和最接近的两堆&#xff0c;然后用01背包的套路解答 class Solution { public:int lastStoneWeightII(vector<int>& stones) {int sum 0;for (int i : stones)sum i;i…

C++客户端Qt开发——界面优化(QSS)

1.QSS 如果通过QSS设置的样式和通过C代码设置的样式冲突&#xff0c;则QSS优先级更高 ①基本语法 选择器{属性名&#xff1a;属性值; } 例如&#xff1a; QPushButton {color: red; } 1>指定控件设置样式 #include "widget.h" #include "ui_widget.h&qu…

Unity Editor免登录启动 无需UnityHub

Unity Editor免登录启动项目无需UnityHub&#xff0c;命令行启动项目。需要开发Unity项目&#xff0c;就必须使用 Unity Hub来管理你的项目&#xff0c;还必须要申请一个免费许可&#xff0c;确实有点麻烦&#xff0c;官方已经提供了相关命令行&#xff0c;来直接使用Unity Edi…

qt--做一个拷贝文件器

一、项目要求 使用线程完善文件拷贝器的操作 主窗口不能假死主窗口进度条必须能动改写文件大小的单位&#xff08;自适应&#xff09; 1TB1024GB 1GB1024MB 1MB1024KB 1KB1024字节 二、所需技术 1.QFileDialog 文件对话框 QFileDialog也继承了QDialog类&#xff0c;直接使用静态…

Redis缓存数据库进阶——Redis与分布式锁(6)

分布式锁简介 1. 什么是分布式锁 分布式锁是一种在分布式系统环境下&#xff0c;通过多个节点对共享资源进行访问控制的一种同步机制。它的主要目的是防止多个节点同时操作同一份数据&#xff0c;从而避免数据的不一致性。 线程锁&#xff1a; 也被称为互斥锁&#xff08;Mu…

TypeScript学习篇-类型介绍使用、ts相关面试题

文章目录 基础知识基础类型: number, string, boolean, object, array, undefined, void(代表该函数没有返回值)enum(枚举): 定义一个可枚举的对象typeinterface联合类型: |交叉类型: &any 类型null 和 undefinednullundefined never类型 面试题及实战1. 你觉得使用ts的好处…

Robot Operating System——内部审查(Introspection)Service

大纲 introspection_service检验Parameter值和类型修改内部审查&#xff08;Introspection&#xff09;功能的状态完整代码 introspection_client完整代码 测试参考资料 在ROS 2&#xff08;Robot Operating System 2&#xff09;中&#xff0c;内部审查&#xff08;Introspect…

【中项】系统集成项目管理工程师-第7章 软硬件系统集成-7.3软件集成

前言&#xff1a;系统集成项目管理工程师专业&#xff0c;现分享一些教材知识点。觉得文章还不错的喜欢点赞收藏的同时帮忙点点关注。 软考同样是国家人社部和工信部组织的国家级考试&#xff0c;全称为“全国计算机与软件专业技术资格&#xff08;水平&#xff09;考试”&…

解决WordPress文章引用的图片不显示问题

在使用WordPress发布文章时&#xff0c;有时会遇到复制发布的文档中包含的外链图片无法正常显示的问题。然而&#xff0c;当我们将图片路径复制到浏览器中单独打开时&#xff0c;图片却可以正常显示。以下是解决这一问题的方法。 问题描述 当你在WordPress文章中引用外链图片…

python 裁剪图片

情况&#xff1a; 有时候看视频&#xff0c;看到一个漂亮的妹子&#xff0c;按下 Alt PrintScreen 进行截图之后&#xff0c;会把整个屏幕都截图。 需要适当剪裁一下。 每次打开 PS &#xff0c; 也太慢了。 所以写个代码&#xff0c; 快速处理。 效果对比&#xff1a; 原始…

iOS集成Ionicons库

目录 ​​​​​​​前言 一、ionicons-iOS 二、安装 三、使用方法 1.字体 2.UILabel: 3.UIImage 四、参考文章 前言 Ionicons 是一个完全开源的图标集&#xff0c;包含 1,300 个专为 Web、iOS、Android 和桌面应用程序设计的图标。Ionicons 是为 Ionic Framework 构建…

【2025留学】德国留学真的很难毕业吗?为什么大家不来德国留学?

大家好&#xff01;我是德国Viviane&#xff0c;一句话讲自己的背景&#xff1a;本科211&#xff0c;硕士在德国读的电子信息工程。 之前网上一句热梗&#xff1a;“德国留学三年将是你人生五年中最难忘的七年。”确实&#xff0c;德国大学的宽进严出机制&#xff0c;延毕、休…

OOP知识整合----集合

目录 一、定义 1、集合: ( 不限制长度&#xff0c;存多少是多少) 2、集合框架: 二、List集合中常用的方法 1、Boolean add(Object o) 2、void add(int index,Object o) 3、Boolean remove(Object o) 4、Object remove(int index) 5、int size() 6、Boolean conta…

springboot集成mybatis时,dao层的mapper类需要添加@Repository注解吗?

在Spring Boot项目中&#xff0c;当你使用MyBatis作为ORM框架时&#xff0c;关于DAO层的Mapper类是否需要添加Repository注解&#xff0c;这主要取决于你的项目需求和配置。 Repository注解的作用Repository注解是Spring框架中用于声明持久层&#xff08;DAO层&#xff09;的组…