我们在写linux的服务的时候,经常会用到linux的多线程技术以提高程序性能
一个应用程序可以启动若干个线程。
线程(Lightweight Process,LWP),是程序执行的最小单元。
一般一个最简单的程序最少会有一个线程,就是程序本身,也就是主函数(单线程的进程可以简单的认为只有一个线程的进程)
一个线程阻塞并不会影响到另外一个线程。
多线程的进程可以尽可能的利用系统CPU资源。
先上一段在一个进程中创建一个线程的简单的代码,然后慢慢深入。
#include
#include
#include
#include
#include void * func(void * arg)
{ printf("func run...
");return NULL;
}
int main()
{ pthread_t t1;int err = pthread_create(&t1,NULL,func,NULL);if(err!=0){ printf("thread_create Failed:%s
",strerror(errno));}else{ printf("thread_create success
");}sleep(1);return EXIT_SUCCESS;}
int pthread_create(pthread_t *thread,const pthread_attr_t *attr, void *(start_routine)(void), void *arg);
在main函数里面我们调用上面的函数进行创建一个线程。
函数参数:
第一个参数:pthread_t代表创建线程的唯一标识,是一个结构体,需要我们创建好后,将这个结构体的指针传递过去。
第二个参数:pthread_attr_t,代表创建这个线程的一些配置,比如分配栈的大小等等。。一般我们可以填NULL,代表默认的创建线程的配置
第三个参数:代表一个函数的地址,创建线程时,会调用这个函数,函数的返回值是void*,函数的参数也是void*,一般格式就像void * func(void * arg){}
第四个参数:代表调用第三个函数传递的参数
函数返回值:
函数成功返回0,如果不等于0则代表函数调用失败,此时通过strerror(errno)可以打印出具体的错误。
注意:每个线程都拥有一份errno副本,不同的线程拥有不同的errno
最后通过gcc编译
gcc 1createthread.c -c -o 1createthread.o
gcc 1createthread.o -o thr1 -lpthread
编译的时候需要加上-lpthread 用来链接libpthread.so动态库,不然会提示找不到function
函数调用返回结果
问题:为什么调用sleep函数
答:可能新创建的线程还没运行到打印的方法主线程就结束了,而主线程结束,所有线程都会结束了。
有时候我们在一个线程中创建了另外一个线程,主线程要等到创建的线程返回了,获取该线程的返回值后主线程才退出。这个时候就需要用到线程挂起。
int pthread_join(pthread_t th, void **thr_return);。
pthread_join函数用于挂起当前线程,直至th指定的线程终止为止。
#include
#include
#include
#include
#include void * func(void * arg)
{ int i=0;for(;i<5;i++){ printf("func run%d
",i);sleep(1);}int * p = (int *)malloc(sizeof(int));*p=11;return p;}
int main()
{ pthread_t t1,t2;int err = pthread_create(&t1,NULL,func,NULL);if(err!=0){ printf("thread_create Failed:%s
",strerror(errno));}else{ printf("thread_create success
");}void *p=NULL;pthread_join(t1,&p);printf("线程退出:code=%d
",*(int*)p);return EXIT_SUCCESS;}
函数执行结果
我们主函数一直在等待创建的线程执行完,并且得到了线程执行结束的返回值
进程终止时exit()函数,那么线程终止是什么呢?
线程终止的三种情况:
#include
#include
#include
#include
#include void * func(void * arg)
{ int i=0;while(1){ if(i==10){ int * p = (int *)malloc(sizeof(int));*p=11;pthread_exit(p);}printf("fun run %d
",i++);sleep(1);}return NULL;}
int main()
{ pthread_t t1,t2;int err = pthread_create(&t1,NULL,func,NULL);if(err!=0){ printf("thread_create Failed:%s
",strerror(errno));}else{ printf("thread_create success
");}void *p=NULL;pthread_join(t1,&p);printf("线程退出:code=%d",*(int*)p);return EXIT_SUCCESS;}
void pthread_exit(void *arg);
pthread_exit函数的参数就跟正常线程结束return的使用时一样的,都会被等待它结束的主线程获取到。
函数运行结果:
int pthread_detach(pthread_t th);
pthread_detach函数使线程处于被分离状态。
如果不等待一个线程,同时对线程的返回值不感兴趣,可以设置这个线程为被分离状态,让系统在线程退出的时候自动回收它所占用的资源。
一个线程不能自己调用pthread_detach改变自己为被分离状态,只能由其他线程调用pthread_detach。
int pthread_cancel(pthread_t th);
pthread_cancel函数允许一个线程取消th指定的另一个线程。
函数成功,返回0,否则返回非0。
#include
#include
#include
#include
#include void * func1(void * arg)
{ while(1){ printf("fun run...
");sleep(1);}return NULL;
}
int main()
{ pthread_t t1;if(pthread_create(&t1,NULL,func1,NULL)!=0){ printf("thread_create Failed:%s
",strerror(errno));return -1;}sleep(5);pthread_cancel(t1);pthread_join(t1,NULL);return EXIT_SUCCESS;}
函数执行结果:
上面我们说过创建一个线程函数pthread_create的第二个参数,用来决定创建线程的一些初始化状态,这里我们 举个例子,改线程一创建就是分离状态的线程(
上面介绍了pthread_detach函数的概念,可以通过pthread_attr_t在创建线程的时候就指定线程属性为detach,而不用创建以后再去修改线程属性。
)
先上一段代码:
#include
#include
#include
#include
#include void * func(void * arg)
{ int i=0;for(;i<5;i++){ printf("func run%d
",i);sleep(1);}int * p = (int *)malloc(sizeof(int));*p=11;return p;}
int main()
{ pthread_t t1;pthread_attr_t attr;//申明一个attr的结构体pthread_attr_init(&attr);//初始化结构体pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);//设置线程为分离线程int err = pthread_create(&t1,&attr,func,NULL);if(err!=0){ printf("thread_create Failed:%s
",strerror(errno));}else{ printf("thread_create success
");}pthread_attr_destroy(&attr);pthread_join(t1,NULL);printf("主线程退出
");return EXIT_SUCCESS;}
pthread_attr_t就是我们要传入的参数的结构体,一般申明的步骤有
申明一个pthread_attr_t对象
函数pthread_attr_init初始化attr结构。
设置线程的一些属性,比如pthread_attr_setdetachstate函数就是设置该线程创建的时候为正常状态还是分离状态。
函数pthread_attr_destroy释放attr内存空间
pthread_attr_setdetachstate把线程属性设置为下面两个合法值之一:
上面函数运行结果:
因为线程是个分离状态的,所以pthread_join挂起会失效,主线程很快运行结束,程序也就结束了,创建的线程还没来得及运行
有时候我们多个线程处理订单扣减库存会遇到这样的问题,两个线程同时进入一段代码先查询库存,两个都查出来为还剩一件库存,第一个线程用掉这个库存后,将库存变为0,但是第二个线程刚才也查出来为1了,所以他还认为有库存,
这个时候操作就会引发我们想不到的意外,库存变为负数了!!所以这个时候就需要使用线程的同步!!
先上一段代码看看效果:
#include
#include
#include
#include
#include
#include
#include void * func(void * arg)
{ int threadno =*(int*)arg;int i=0;for(;i<10;i++){ printf("%d thread%d
",threadno,i);sleep(1);}return NULL;}
int main()
{ pthread_t t1,t2;int i1=1,i2=2;pthread_create(&t1,NULL,func,&i1);pthread_create(&t2,NULL,func,&i2);pthread_join(t1,NULL);pthread_join(t2,NULL);printf("主线程退出
");return EXIT_SUCCESS;}
函数运行结果:
可以看到两个线程是没有规律的争相处理的,如果这段代码是扣减库存就完蛋啦!,所以我们要对这段代码进行加锁,同一时刻只能有一个线程进入操作!
#include
#include
#include
#include
#include pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;void * func(void * arg)
{ pthread_mutex_lock(&mutex);//对mutex加锁,其他线程进入后将会挂起,知道这个锁被解锁int threadno =*(int*)arg;int i=0;for(;i<10;i++){ printf("%d thread%d
",threadno,i);sleep(1);}pthread_mutex_unlock(&mutex);return NULL;}
int main()
{ pthread_t t1,t2;int i1=1,i2=2;pthread_create(&t1,NULL,func,&i1);pthread_create(&t2,NULL,func,&i2);pthread_join(t1,NULL);pthread_join(t2,NULL);printf("主线程退出
");return EXIT_SUCCESS;}
函数运行结果:
可以看到第二个线程先进入后一直运行结束,对mutex解锁后,第一个线程才能进方法里面运行!否则会挂起,一直等到锁被解锁!
PTHREAD_MUTEX_INITIALIZER是初始化一个快速锁的宏定义。
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
加锁解锁函数:
int pthread_mutex_lock(pthread_mutex_t *mutex);
int pthread_mutex_unlock(pthread_mutex_t *mutex);
多线程有什么好处?提高CPU的利用率,更好地利用系统资源,使用Monitor类可以同步静态/实例化的方法的全部代码或者部分代码段,使用不同的同步类创建自己的同步机制。多线程指从软件或者硬件上实现多个线程并发执行的技术。具有多线程能力的计算机因有硬件支持而能够在同一时间执行多于一个线程提升整体处理性能。多线程是指程序中包含多个执行流,即...
Step1:在界面主函数的构造函数中初始化多线程 auto mythread = new QThread(); //新建connect(mythread , &QThread::finished, mythread, &QObject::deleteLater);//线程运行结束后释放内存object1->moveToThread...
一、thread的基本用法
参见C++使用thread类多线程编程 。
二、类外使用多线程,访问类的成员
这几种方式,新建线程都是在类外,然后通过把友元函数或者成员函数作为thread参数。
#include
本博文是根据中科大信息学院谭立湘老师的课件加上自己的理解整理出来的 ************************************************************************************ NVIDIA在2007年推出CUDA这个统一计算架构 CUDA的基本思想是支持大量的线程级并...
一、parallel communication patterns 并行通信模式 Map:映射,在特定的位置读取和写入。 Gather:收集,从多个不同的位置读入,写入一个位置。 Scatter:分发,写入多个位置。 Transpose转置 结构数组缩写为AOS,数组结构缩写为SOA 转置运算是指任务重新排序内存中的数...
函数原型 int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex) 第一个参数为需要等待的条件,第二个参数为互斥锁 一般该函数和 int pthread_cond_signal(pthread_cond_t *cond);函数一同使用,用来唤醒在cond...
Apache POI是一个开源的利用Java读写Excel,WORD等微软OLE2组件文档的项目。 我的需求是对Excel的数据进行导入或将数据以Excel的形式导出。先上简单的测试代码:package com.xing.studyTest.poi;import java.io.FileInputSt...
要取得[a,b)的随机整数,使用(rand() % (b-a))+ a; 要取得[a,b]的随机整数,使用(rand() % (b-a+1))+ a; 要取得(a,b]的随机整数,使用(rand() % (b-a))+ a + 1; 通用公式:a + rand() % n;其中的a是起始值,n是整数的范围。 要取得a到b之间的...
利用本征图像分解(Intrinsic Image Decomposition)算法,将图像分解为shading(illumination) image 和 reflectance(albedo) image,计算图像的reflectance image。 Reflectance Image 是指在变化的光照条件下能够维持不变的图像部分...
题目:面试题39. 数组中出现次数超过一半的数字 数组中有一个数字出现的次数超过数组长度的一半,请找出这个数字。 你可以假设数组是非空的,并且给定的数组总是存在多数元素。 示例 1: 输入: [1, 2, 3, 2, 2, 2, 5, 4, 2] 输出: 2 限制: 1 <= 数组长度 <= 50000 解题: cl...
题目:二叉搜索树的后序遍历序列 输入一个整数数组,判断该数组是不是某二叉搜索树的后序遍历结果。如果是则返回 true,否则返回 false。假设输入的数组的任意两个数字都互不相同。 参考以下这颗二叉搜索树: 5 / 2 6 / 1 3示例 1: 输入: [1,6,3,2,5] 输出...