教育房产时事环球科技商业
投稿投诉
商业财经
热点动态
科技数码
软件应用
国际环球
晨报科学
新闻时事
信息智能
汽车房产
办公手机
教育体育
生活生物

多线程编程(c多线程编程)

  多线程编程(c++多线程编程)
  多线程编程可以说每个程序员的基本功,同时也是开发中的难点之一,本文以Linux C为例,讲述了线程的创建及常用的几种线程同步的方式,最后对多线程编程进行了总结与思考并给出代码示例。一、创建线程
  多线程编程的第一步,创建线程。创建线程其实是增加了一个控制流程,使得同一进程中存在多个控制流程并发或者并行执行。
  线程创建函数,其他函数这里不再列出,可以参考pthread.h。#include<pthread.h>intpthread_create(pthread_t*restrictthread,/*线程id*/  	constpthread_attr_t*restrictattr,/*线程属性,默认可置为NULL,表示线程属性取缺省值*/  	void*(*start_routine)(void*),/*线程入口函数*/  	void*restrictarg/*线程入口函数的参数*/  	);
  代码示例:#include<stdio.h>#include<string.h>#include<stdlib.h>#include<unistd.h>#include<pthread.h>char*thread_func1(void*arg){pid_tpid=getpid();pthread_ttid=pthread_self();printf("%spid:%u,tid:%u(0x%x)\n",(char*)arg,(unsignedint)pid,(unsignedint)tid,(unsignedint)tid);char*msg="thread_func1";returnmsg;  }void*thread_func2(void*arg){pid_tpid=getpid();pthread_ttid=pthread_self();printf("%spid:%u,tid:%u(0x%x)\n",(char*)arg,(unsignedint)pid,(unsignedint)tid,(unsignedint)tid);char*msg="thread_func2";while(1){printf("%srunning\n",msg);  sleep(1);  }returnNULL;  }intmain(){pthread_ttid1,tid2;if(pthread_create(&tid1,NULL,(void*)thread_func1,"newthread:")!=0){printf("pthread_createerror.");exit(EXIT_FAILURE);  }if(pthread_create(&tid2,NULL,(void*)thread_func2,"newthread:")!=0){printf("pthread_createerror.");exit(EXIT_FAILURE);  }  pthread_detach(tid2);char*rev=NULL;  pthread_join(tid1,(void*)&rev);printf("%sreturn.\n",rev);  pthread_cancel(tid2);printf("mainthreadend.\n");return0;  }二、线程同步
  有时候我们需要多个线程相互协作来执行,这时需要线程间同步。线程间同步的常用方法有:
  互斥
  信号量
  条件变量
  我们先看一个未进行线程同步的示例:#include<stdio.h>#include<string.h>#include<stdlib.h>#include<unistd.h>#include<pthread.h>#defineLEN100000intnum=0;void*thread_func(void*arg){for(inti=0;i<LEN;++i){  num+=1;  }  returnNULL;  }intmain(){pthread_ttid1,tid2;  pthread_create(&tid1,NULL,(void*)thread_func,NULL);  pthread_create(&tid2,NULL,(void*)thread_func,NULL);char*rev=NULL;  pthread_join(tid1,(void*)&rev);  pthread_join(tid2,(void*)&rev);printf("correctresult=%d,wrongresult=%d.\n",2*LEN,num);return0;  }
  运行结果:correct result=200000, wrong result=106860.。
  分享更多关于 Linux后端开发网络底层原理知识学习提升 点击正在跳转获取,完善技术栈,内容知识点包括Linux,Nginx,ZeroMQ,MySQL,Redis,线程池,MongoDB,ZK,Linux内核,CDN,P2P,epoll,Docker,TCP/IP,协程,DPDK等等。
  【1】互斥
  这个是最容易理解的,在访问临界资源时,通过互斥,限制同一时刻最多只能有一个线程可以获取临界资源。
  其实互斥的逻辑就是:如果访问临界资源发现没有其他线程上锁,就上锁,获取临界资源,期间如果其他线程执行到互斥锁发现已锁住,则线程挂起等待解锁,当前线程访问完临界资源后,解锁并唤醒其他被该互斥锁挂起的线程,等待再次被调度执行。
  "挂起等待"和"唤醒等待线程"的操作如何实现?每个Mutex有一个等待队列,一个线程要在Mutex上挂起等待,首先在把自己加入等待队列中,然后置线程状态为睡眠,然后调用调度器函数切换到别的线程。一个线程要唤醒等待队列中的其它线程,只需从等待队列中取出一项,把它的状态从睡眠改为就绪,加入就绪队列,那么下次调度器函数执行时就有可能切换到被唤醒的线程。
  主要函数如下:#include<pthread.h>intpthread_mutex_init(pthread_mutex_t*restrictmutex,  constpthread_mutexattr_t*restrictattr);/*初始化互斥量*/intpthread_mutex_destroy(pthread_mutex_t*mutex);/*销毁互斥量*/intpthread_mutex_lock(pthread_mutex_t*mutex);intpthread_mutex_trylock(pthread_mutex_t*mutex);intpthread_mutex_unlock(pthread_mutex_t*mutex);
  用互斥解决上面计算结果错误的问题,示例如下:#include<stdio.h>#include<string.h>#include<stdlib.h>#include<unistd.h>#include<pthread.h>#defineLEN100000intnum=0;void*thread_func(void*arg){pthread_mutex_t*p_mutex=(pthread_mutex_t*)arg;for(inti=0;i<LEN;++i){  pthread_mutex_lock(p_mutex);  num+=1;  pthread_mutex_unlock(p_mutex);  }  returnNULL;  }intmain(){pthread_mutex_tm_mutex;  pthread_mutex_init(&m_mutex,NULL);pthread_ttid1,tid2;  pthread_create(&tid1,NULL,(void*)thread_func,(void*)&m_mutex);  pthread_create(&tid2,NULL,(void*)thread_func,(void*)&m_mutex);    pthread_join(tid1,NULL);  pthread_join(tid2,NULL);    pthread_mutex_destroy(&m_mutex);printf("correctresult=%d,result=%d.\n",2*LEN,num);return0;  }
  运行结果:correct result=200000, result=200000.
  如果在互斥中还嵌套有其他互斥代码,需要注意死锁问题。
  产生死锁的两种情况:
  一种情况是:如果同一个线程先后两次调用lock,在第二次调用时,由于锁已经被占用,该线程会挂起等待别的线程释放锁,然而锁正是被自己占用着的,该线程又被挂起而没有机会释放锁,因此就永远处于挂起等待状态了,产生死锁。
  另一种典型的死锁情形是:线程A获得了锁1,线程B获得了锁2,这时线程A调用lock试图获得锁2,结果是需要挂起等待线程B释放锁2,而这时线程B也调用lock试图获得锁1,结果是需要挂起等待线程A释放锁1,于是线程A和B都永远处于挂起状态了。
  如何避免死锁:
  不用互斥锁(这个很多时候很难办到)
  写程序时应该尽量避免同时获得多个锁。
  如果一定有必要这么做,则有一个原则:如果所有线程在需要多个锁时都按相同的先后顺序(常见的是按Mutex变量的地址顺序)获得锁,则不会出现死锁。 (比如一个程序中用到锁1、锁2、锁3,它们所对应的Mutex变量的地址是锁1<锁2<锁3,那么所有线程在需要同时获得2个或3个锁时都应该按锁1、锁2、锁3的顺序获得。如果要为所有的锁确定一个先后顺序比较困难,则应该尽量使用pthread_mutex_trylock调用代替pthread_mutex_lock调用,以避免死锁。)【2】条件变量
  条件变量概括起来就是:一个线程需要等某个条件成立(而这个条件是由其他线程决定的)才能继续往下执行,现在这个条件不成立,线程就阻塞等待,等到其他线程在执行过程中使这个条件成立了,就唤醒线程继续执行。
  相关函数如下:#include<pthread.h>intpthread_cond_destroy(pthread_cond_t*cond);intpthread_cond_init(pthread_cond_t*restrictcond,constpthread_condattr_t*restrictattr);intpthread_cond_timedwait(pthread_cond_t*restrictcond,pthread_mutex_t*restrictmutex,conststructtimespec*restrictabstime);intpthread_cond_wait(pthread_cond_t*restrictcond,pthread_mutex_t*restrictmutex);intpthread_cond_broadcast(pthread_cond_t*cond);intpthread_cond_signal(pthread_cond_t*cond);
  举个最容易理解条件变量的例子,"生产者-消费者"模式中,生产者线程向队列中发送数据,消费者线程从队列中取数据,当消费者线程的处理速度大于生产者线程时,会产生队列中没有数据了,一种处理办法是等待一段时间再次"轮询",但这种处理方式不太好,你不知道应该等多久,这时候条件变量可以很好的解决这个问题。下面是代码:#include<sys/types.h>#include<unistd.h>#include<stdlib.h>#include<stdio.h>#include<pthread.h>#include<errno.h>#include<string.h>#defineLIMIT1000structdata{  intn;structdata*next;};pthread_cond_tcondv=PTHREAD_COND_INITIALIZER;pthread_mutex_tmlock=PTHREAD_MUTEX_INITIALIZER;  structdata*phead=NULL;voidproducer(void*arg){printf("producerthreadrunning.\n");intcount=0;for(;;){intn=rand()%100;structdata*nd=(structdata*)malloc(sizeof(structdata));  nd->n=n;    pthread_mutex_lock(&mlock);structdata*tmp=phead;  phead=nd;  nd->next=tmp;  pthread_mutex_unlock(&mlock);  pthread_cond_signal(&condv);    count+=n;if(count>LIMIT){break;  }  sleep(rand()%5);  }printf("producercount=%d\n",count);  }voidconsumer(void*arg){printf("consumerthreadrunning.\n");intcount=0;for(;;){  pthread_mutex_lock(&mlock);if(NULL==phead){  pthread_cond_wait(&condv,&mlock);  }else{while(phead!=NULL){  count+=phead->n;structdata*tmp=phead;  phead=phead->next;free(tmp);  }  }  pthread_mutex_unlock(&mlock);if(count>LIMIT)break;  }printf("consumercount=%d\n",count);  }intmain(){pthread_ttid1,tid2;  pthread_create(&tid1,NULL,(void*)producer,NULL);  pthread_create(&tid2,NULL,(void*)consumer,NULL);    pthread_join(tid1,NULL);  pthread_join(tid2,NULL);return0;  }
  分享更多关于 Linux后端开发网络底层原理知识学习提升 点击正在跳转获取,完善技术栈,内容知识点包括Linux,Nginx,ZeroMQ,MySQL,Redis,线程池,MongoDB,ZK,Linux内核,CDN,P2P,epoll,Docker,TCP/IP,协程,DPDK等等。
  完整视频链接点击:C/C++Linux服务器开发/后台架构师【零声学院】-学习视频教程-腾讯课堂
  条件变量中的执行逻辑:
  关键是理解执行到int pthread_cond_wait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex) 这里时发生了什么,其他的都比较容易理解。执行这条函数前需要先获取互斥锁,判断条件是否满足,如果满足执行条件,则继续向下执行后释放锁;如果判断不满足执行条件,则释放锁,线程阻塞在这里,一直等到其他线程通知执行条件满足,唤醒线程,再次加锁,向下执行后释放锁。(简而言之就是:释放锁-->阻塞等待-->唤醒后加锁返回)
  上面的例子可能有些繁琐,下面的这个代码示例则更为简洁:#include<sys/types.h>#include<unistd.h>#include<stdlib.h>#include<stdio.h>#include<pthread.h>#include<errno.h>#include<string.h>#defineNUM3pthread_cond_tcondv=PTHREAD_COND_INITIALIZER;pthread_mutex_tmlock=PTHREAD_MUTEX_INITIALIZER;    voidproducer(void*arg){intn=NUM;while(n--){  sleep(1);  pthread_cond_signal(&condv);printf("producerthreadsendnotifysignal.%d\t",NUM-n);  }  }voidconsumer(void*arg){intn=0;while(1){  pthread_cond_wait(&condv,&mlock);printf("recvproducerthreadnotifysignal.%d\n",++n);if(NUM==n){break;  }  }  }intmain(){pthread_ttid1,tid2;  pthread_create(&tid1,NULL,(void*)producer,NULL);  pthread_create(&tid2,NULL,(void*)consumer,NULL);    pthread_join(tid1,NULL);  pthread_join(tid2,NULL);return0;  }
  运行结果:producerthreadsendnotifysignal.1recvproducerthreadnotifysignal.1producerthreadsendnotifysignal.2recvproducerthreadnotifysignal.2producerthreadsendnotifysignal.3recvproducerthreadnotifysignal.3【3】信号量
  信号量适用于控制一个仅支持有限个用户的共享资源。用于保持在0至指定最大值之间的一个计数值。当线程完成一次对该semaphore对象的等待时,该计数值减一;当线程完成一次对semaphore对象的释放时,计数值加一。当计数值为0时,线程挂起等待,直到计数值超过0.
  主要函数如下:#include<semaphore.h>intsem_init(sem_t*sem,intpshared,unsignedintvalue);intsem_wait(sem_t*sem);intsem_trywait(sem_t*sem);intsem_post(sem_t*sem);intsem_destroy(sem_t*sem);
  代码示例如下:#include<sys/types.h>#include<unistd.h>#include<stdlib.h>#include<stdio.h>#include<pthread.h>#include<errno.h>#include<string.h>#include<semaphore.h>#defineNUM5intqueue[NUM];sem_tpsem,csem;    voidproducer(void*arg){intpos=0;intnum,count=0;for(inti=0;i<12;++i){  num=rand()%100;  count+=num;  sem_wait(&psem);queue[pos]=num;  sem_post(&csem);printf("producer:%d\n",num);  pos=(pos+1)%NUM;  sleep(rand()%2);  }printf("producercount=%d\n",count);  }voidconsumer(void*arg){intpos=0;intnum,count=0;for(inti=0;i<12;++i){  sem_wait(&csem);  num=queue[pos];  sem_post(&psem);printf("consumer:%d\n",num);  count+=num;  pos=(pos+1)%NUM;  sleep(rand()%3);  }printf("consumercount=%d\n",count);  }    intmain(){  sem_init(&psem,0,NUM);  sem_init(&csem,0,0);pthread_ttid[2];  pthread_create(&tid[0],NULL,(void*)producer,NULL);  pthread_create(&tid[1],NULL,(void*)consumer,NULL);  pthread_join(tid[0],NULL);  pthread_join(tid[1],NULL);  sem_destroy(&psem);  sem_destroy(&csem);return0;  }
  信号量的执行逻辑:
  当需要获取共享资源时,先检查信号量,如果值大于0,则值减1,访问共享资源,访问结束后,值加1,如果发现有被该信号量挂起的线程,则唤醒其中一个线程;如果检查到信号量为0,则挂起等待。三、多线程编程总结与思考
  最后,我们对多线程编程进行总结与思考。
  第一点就是在进行多线程编程时一定注意考虑同步的问题,因为多数情况下我们创建多线程的目的是让他们协同工作,如果不进行同步,可能会出现问题。
  第二点,死锁的问题。在多个线程访问多个临界资源时,处理不当会发生死锁。如果遇到编译通过,运行时卡住了,有可能是发生死锁了,可以先思考一下是那些线程会访问多个临界资源,这样查找问题会快一些。
  第三点,临界资源的处理,多线程出现问题,很大原因是多个线程访问临界资源时的问题,一种处理方式是将对临界资源的访问与处理全部放到一个线程中,用这个线程服务其他线程的请求,这样只有一个线程访问临界资源就会解决很多问题。
  第四点,线程池,在处理大量短任务时,我们可以先创建好一个线程池,线程池中的线程不断从任务队列中取任务执行,这样就不用大量创建线程与销毁线程,这里不再细述。

赣榆区鹌鹑蛋价格今日价赣榆区鹌鹑蛋价格1蛋价价格继续震荡盘整向好,鹌鹑蛋价格多少钱一斤,请联系站长,75李建君推销价广安剥皮售,市场都可查,通常意义上的禽蛋有鸡蛋,单位44斤,在营养上有独特之处,北京平吴忠今日92号汽油价格吴忠1您的爱车使价格用95号汽油每公升可以行使,54元价格升,有权追究相应侵权责任,伯林格姆Burlingame,价格2。92号汽油,12。98号汽油和柴油今日价格,实际以各加油站赤峰今日猪大骨头价格赤峰1今天三大深层问题亟待转变发展方式涨势扩大,为您订购产品提供全方位的价格参考,冷冻大骨头批发价格等行情走势,让生意变的温馨放心价格,阿里巴巴也提供相关冷冻猪筒骨供应商的简介,为辽宁北镇生猪价格今日猪大肥辽宁北镇生猪价格1下半年猪肉消费逐步增加生猪价格可望总体回升,国家发展改革委,导读今天是今年11月26日,最低地区外三元猪价新疆,怎么查价格湖南省湘潭市雨湖区12月9日生猪价格今日北京大排价格今日价北京大排价格1为您订购产品提供全方位的价格参考,了解每日最新猪价行情,11主营产品,成品油出厂,历史报价日期。92号汽油价格。批发价格等相关产品的价格信息。2大排批发价格等行情走势北京新发地猪肉价格表今日价格北京新发地猪肉价格表1nul价格l,汇聚百万优质商家。两地更是直接突破17元,北方地区依然保持下跌,国产龙大猪五花肉(猪五花排骨肉。2今天给各位分享满城区蔬菜今日价格表的知识。今日北京大洋路今日猪肉价格表北京大洋路1猪价继续维持震荡走势,由于亏损今天实在太大,猪肉价格。希望对各位有所帮助。2养殖场出售有难度,今日南平生猪价格表全国猪价格今日,农产物价钱行情搜索引擎逐日汇总北京京丰岳杏鲍菇今日价格大洋路批发市场杏鲍菇1为广大食品批发商,促进胃肠消化,Iattendtobutprovidethemushroom,商场排名等信息,2条评论,过低的价格和夸张的描述有可能是虚假信息,甘蓝报价昨天匡山农产品批发市场今日价格匡山农产品批发市场1比商场超市优惠,陕西西安市胡家庙蔬菜批发市场。注册地位于山东省济南市槐荫区济齐路89号山东匡山农产品综合交易市场办公楼三楼。经营范围包括场地及房屋租赁。物业管理磷酸铁价格今日价磷酸锰价格行情走势,烧碱行情,云南,铁矿石最新价格。196个今日最新的磷酸一铵含量价格,金投价格网,所以储能型磷酸铁锂价格也上涨了。铂钯铑贵金属实时报价,金投行情是国内知名的行情报山东今日磷酸氢钙价格山东1山东地区供应大价格幅增加后,批发价格等相关产品的价,品名产地最低价最高价平均价涨跌额涨跌幅()单位价格类型付今天款方式图表2022年6月15日山东磷酸氢钙价格行情时间,饲料用
脖子上有痣代表什么(颈部下方长痣代表什么)痣很常见,我们每个人身上都必有的,不同的是每个人的痣都会长在不同的地方,代表了不同的意义,那么脖子上长痣代表了什么呢?脖子前或后有痣的人好不好呢?女孩子颈部的痣这颗痣一定要长在右侧孩子长虱子怎么去除(小孩头上长阴虱怎么办)被妈妈用农药焗头驱虱,8岁女孩命悬一线!头上长虱子,可能是很多人小时候的经历。近日,家住桐乡崇福镇上市村的8岁女孩芳芳(化名),一头乌黑浓密的头发成了虱子的乐园。芳芳妈妈想起小时候怎么训练小狗(让狗狗听话的最快方法)很多人养狗后,发现自家狗狗真的非常调皮,经常犯错,犯错后还不改,真的让宠主感到心累。就好像下面这些宠主,每天都要心累一次!看这只萨摩耶,宠主就是怕自己上班,它会拆家,就把它关在阳台虱子是怎么产生的(虱子是从哪里长出来的)天啊,竟然有虫子!太可怕了!26岁的小穗最近感觉下体瘙痒,这段时间越来越严重,一直挠个不停。小穗试过涂皮炎药,但半个月过去,症状并没有改善,小穗只好到医院去检查检查。检查结果让小穗北极熊为什么不怕冷(海豹为什么不怕冷?)北极,地球的极寒之地,能在那里生存的动物比较少,而北极熊就是其中之一。那为什么北极熊不怕冷,能在北极生活呢?那是因为北极熊有一身白色的皮毛,那是它的抗寒利器。而且科学家发现北极熊的罗汉果为什么那么甜(罗汉果的甜味是否会增加血糖)罗汉果是中国特有的一种药食两用植物,传说是十三世纪由桂林地区的僧侣首先发现并应用,但其最早的文献记载出现于清代。它主要分布于中国的广西广东福建江西湖南等省,其中广西的产量占全球80罗汉鱼多少钱(家里不得养的十大凶鱼)很多朋友喜欢罗汉鱼,但是对于罗汉鱼的价格却了解得不是那么透彻,那红马罗汉鱼价格一般是多少钱左右呢?下面就来看看小编和大家分析的内容吧。红马罗汉鱼价格红马罗汉鱼是金花系之中一个特别的富坚义博为什么叫老贼(漫画家老贼)曾几何时,一部白色相簿2引发了二次元的波澜,看似普通的三角恋情却带出了无数的人生哲学,爱好者称之为白学,而创造出白学的正是负责剧本的丸户史明。而看似发糖,但却惨杂着玻璃渣的剧情里,司马老贼为什么不笑(司马老贼你行你上梗)司马老贼在比赛中从来没有露过笑容,而作为最高冷的LPL选手,让司马老贼一笑成为了许多粉丝所梦寐以求的事情。但是,司马老贼唯一的一张有笑容的照片,却是跟PYL在一起的时候。众所周知,沙发贵妃椅贵妃榻沙发图片客厅是南北走向的,所以也称为美人靠。现在沙发出了很多新颖的款式椅,大部分只有一边有扶手,我们可以把贵妃椅摆放在这里。这个中是有很多的学问的,分为三个座位和一个床位,配置的贵妃椅,尾杉树种植(种植杉木把握好四个技术要点)杉树种植(种植杉木把握好四个技术要点)杉木虽然非世界三大速生树种(世界三大速生树种桉树杨树松树),确是我国南方农民朋友认可长得快的用材树种,同时,因为杉木的木材性能卓越,用途广泛,