百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术分析 > 正文

Linux后台开发技术之多线程实现多任务

liebian365 2024-10-19 07:59 24 浏览 0 评论

每个进程都拥有自己的数据段、代码段和堆栈段,这就造成进程在进行创建、切换、撤销操作时,需要较大的系统开销。为了减少系统开销,从进程中演化出了线程。为了让进程完成一定的工作,进程必须至少包含一个线程。线程存在于进程中,共享进程的资源。

就像每个进程都有一个进程号一样,每个线程也有一个线程号。进程号在整个系统中是唯一的,但线程号不同,线程号只在它所属的进程环境中有效。进程号用 pid_t 数据类型表示,是一个非负整数。线程号则用 pthread_t 数据类型来表示,Linux 使用无符号长整数表示。有的系统在实现 pthread_t 的时候,用一个结构体来表示,所以在可移植的操作系统实现不能把它做为整数处理。

线程的常用函数

1)获取线程号

所需头文件:

#include <pthread.h>
pthread_t pthread_self(void);
功能:获取线程号。
参数:无
返回值:调用线程的线程 ID 。

2)线程号的比较

所需头文件:

#include <pthread.h>
int pthread_equal(pthread_t t1, pthread_t t2);
功能:判断线程号 t1 和 t2 是否相等。为了方便移植,尽量使用函数来比较线程 ID。
参数:t1,t2:待判断的线程号。
返回值:相等:  非 0        不相等:0

示例代码:

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
 
int main(int argc, char *argv[])
{
	pthread_t thread_id;
 
	thread_id = pthread_self(); // 返回调用线程的线程ID
	printf("Thread ID = %lu \n",thread_id);
 
	if( 0 != pthread_equal( thread_id, pthread_self() ) ){
		printf("Equal!\n");
	}else{
		printf("Not equal!\n");
	}
	
	return 0;
}

线程函数的程序在 pthread 库中,故链接时要加上参数 -lpthread。

运行结果如下:

3)线程的创建

所需头文件:

#include <pthread.h>

int pthread_create( pthread_t *thread,

const pthread_attr_t *attr,
void *(*start_routine)(void *),
void *arg );

功能:创建一个线程。

参数:

  • thread:线程标识符地址。
  • attr:线程属性结构体地址,通常设置为 NULL。
  • start_routine:线程函数的入口地址。
  • arg:传给线程函数的参数。

返回值:成功:0 失败:非 0

pthread_create() 创建的线程从指定的回调函数开始运行,该函数运行完后,该线程也就退出了。线程依赖进程存在的,共享进程的资源,如果创建线程的进程结束了,线程也就结束了。

示例一:

#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
 
int var  = 8;
 
void *thread_1(void *arg)
{
	while(1)
	{
		printf("this is my new thread1: var++\n");
		var++;
		sleep(1);
	}
	return NULL;
}
 
void *thread_2(void * arg)
{
	while(1){
		printf("this is my new thread2: var = %d\n", var);
		sleep(1);
	}
	
	return NULL;
}
 
int main(int argc, char *argv[])
{
	pthread_t tid1,tid2;
	
	//创建两个线程
	pthread_create(&tid1, NULL, thread_1, NULL);  
	pthread_create(&tid2, NULL, thread_2, NULL);
	
	while(1){
		printf("the main thread: var = %d\n", var);
		sleep(1);
	}
	
	return 0;
}

运行结果如下:

示例二:

#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
 
// 回调函数
void *thread_fun(void * arg)
{
	sleep(1);
	int num = *( (int *)arg );
	printf("int the new thread: num = %d\n", num);
	
	return NULL;
}
 
int main(int argc, char *argv[])
{
	pthread_t tid;
	int test = 100;
	
	// 创建线程, 把 &test 传给回调函数 thread_fun()
	pthread_create(&tid, NULL, thread_fun, (void *)&test);  
 
	while(1);
	
	return 0;
}

运行结果如下:

4)回收线程资源

所需头文件:

#include <pthread.h>

int pthread_join(pthread_t thread, void **retval);

功能:等待线程结束(此函数会阻塞),并回收线程资源,类似进程的 wait() 函数。如果线程已经结束,那么该函数会立即返回。

参数:

  • thread:被等待的线程号。
  • retval:用来存储线程退出状态的指针的地址。

返回值:成功:0 失败:非 0

示例代码如下:

#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
 
void *thead(void *arg)
{
	static int num = 123; //静态变量
	
	printf("after 2 seceonds, thread will return\n");
	sleep(2);
	
	return #
}
 
int main(int argc, char *argv[])
{
	pthread_t tid;
	int ret = 0;
	void *value = NULL;
	
	// 创建线程
	ret = pthread_create(&tid, NULL, thead, NULL);
	if(ret != 0){ //创建失败
		perror("pthread_create");
	}
	
	// 等待线程号为 tid 的线程,如果此线程结束就回收其资源
	// &value保存线程退出的返回值
	pthread_join(tid, &value); 
	
	printf("value = %d\n", *( (int *)value ) );
	
	return 0;
}

运行结果如下:

创建一个线程后应回收其资源,但使用 pthread_join() 函数会使调用者阻塞,Linux 还提供了非阻塞函数 pthread_detach() 来回收线程的资源。

所需头文件:

#include <pthread.h>

int pthread_detach(pthread_t thread);

功能:

使调用线程与当前进程分离,分离后不代表此线程不依赖与当前进程,线程分离的目的是将线程资源的回收工作交由系统自动来完成,也就是说当被分离的线程结束之后,系统会自动回收它的资源。所以,此函数不会阻塞。

参数:

  • thread:线程号。

返回值:成功:0 失败:非 0

注意,调用 pthread_detach() 后再调用 pthread_join() , pthread_join() 会立马返回,调用失败。

示例代码如下:

 #include <stdio.h>
#include <unistd.h>
#include <pthread.h>
 
void *thead(void *arg)
{
	int i;
	for(i=0; i<5; i++)
	{
		printf("I am runing\n");
		sleep(1);
	}
	
	return NULL;
}
 
int main(int argc, char *argv[])
{
	int ret  = 0;
	pthread_t tid;
	
	ret = pthread_create(&tid, NULL, thead, NULL);
	if(ret!=0){
		perror("pthread_create");
	}
	
	pthread_detach(tid); // 线程分离,不阻塞
	
	// 立马返回,调用失败
	int flag = pthread_join(tid, NULL);
	if(flag != 0){
		printf("join not working\n");
	}
	
	printf("after join\n");
	sleep(3);
	printf("I am leaving\n");
	
	return 0;
}

运行结果如下:

5)线程退出

在进程中我们可以调用 exit() 函数或 _exit() 函数来结束进程,在一个线程中我们可以通过 pthread_exit() 在不终止整个进程的情况下停止它的控制流。

所需头文件:

#include <pthread.h>

void pthread_exit(void *retval);

功能:

退出调用线程。一个进程中的多个线程是共享该进程的数据段,因此,通常线程退出后所占用的资源并不会释放。

参数:

  • retval:存储线程退出状态的指针。

返回值:无

示例代码如下:

#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
 
void *thread(void *arg)
{
	static int num = 123; //静态变量
	int i = 0;
	while(1)
	{
		printf("I am runing\n");
		sleep(1);
		i++;
		if(i==3)
		{
			pthread_exit( (void *)&num );
			// return #
		}
	}
	
	return NULL;
}
 
int main(int argc, char *argv[])
{
	int ret  = 0;
	pthread_t tid;
	void *value  = NULL;
	
	ret = pthread_create(&tid, NULL, thread, NULL);  
	if(ret!=0){
		perror("pthread_create");
	}
	
	pthread_join(tid, &value);
	
	printf("value = %d\n", *(int *)value );
	
	return 0;
}

运行结果如下:

需要C/C++ Linux服务器架构师学习资料私信“资料”(资料包括C/C++,Linux,golang技术,Nginx,ZeroMQ,MySQL,Redis,fastdfs,MongoDB,ZK,流媒体,CDN,P2P,K8S,Docker,TCP/IP,协程,DPDK,ffmpeg等),免费分享

相关推荐

“版本末期”了?下周平衡补丁!国服最强5套牌!上分首选

明天,酒馆战棋就将迎来大更新,也聊了很多天战棋相关的内容了,趁此机会,给兄弟们穿插一篇构筑模式的卡组推荐!老规矩,我们先来看10职业胜率。目前10职业胜率排名与一周前基本类似,没有太多的变化。平衡补丁...

VS2017 C++ 程序报错“error C2065:“M_PI”: 未声明的标识符&quot;

首先,程序中头文件的选择,要选择头文件,在文件中是没有对M_PI的定义的。选择:项目——>”XXX属性"——>配置属性——>C/C++——>预处理器——>预处理器定义,...

东营交警实名曝光一批酒驾人员名单 88人受处罚

齐鲁网·闪电新闻5月24日讯酒后驾驶是对自己和他人生命安全极不负责的行为,为守护大家的平安出行路,东营交警一直将酒驾作为重点打击对象。5月23日,东营交警公布最新一批饮酒、醉酒名单。对以下驾驶人醉酒...

Qt界面——搭配QCustomPlot(qt platform)

这是我第一个使用QCustomPlot控件的上位机,通过串口精确的5ms发送一次数据,再将读取的数据绘制到图表中。界面方面,尝试卡片式设计,外加QSS简单的配了个色。QCustomPlot官网:Qt...

大话西游2分享赢取种族坐骑手办!PK趣闻录由你书写

老友相聚,仗剑江湖!《大话西游2》2021全民PK季4月激燃打响,各PK玩法鏖战齐开,零门槛参与热情高涨。PK季期间,不仅各种玩法奖励丰厚,参与PK趣闻录活动,投稿自己在PK季遇到的趣事,还有机会带走...

测试谷歌VS Code AI 编程插件 Gemini Code Assist

用ClaudeSonnet3.7的天气测试编码,让谷歌VSCodeAI编程插件GeminiCodeAssist自动编程。生成的文件在浏览器中的效果如下:(附源代码)VSCode...

顾爷想知道第4.5期 国服便利性到底需优化啥?

前段时间DNF国服推出了名为“阿拉德B计划”的系列改版计划,截至目前我们已经看到了两项实装。不过关于便利性上,国服似乎还有很多路要走。自从顾爷回归DNF以来,几乎每天都在跟我抱怨关于DNF里面各种各样...

掌握Visual Studio项目配置【基础篇】

1.前言VisualStudio是Windows上最常用的C++集成开发环境之一,简称VS。VS功能十分强大,对应的,其配置系统较为复杂。不管是对于初学者还是有一定开发经验的开发者来说,捋清楚VS...

还嫌LED驱动设计套路深?那就来看看这篇文章吧

随着LED在各个领域的不同应用需求,LED驱动电路也在不断进步和发展。本文从LED的特性入手,推导出适合LED的电源驱动类型,再进一步介绍各类LED驱动设计。设计必读:LED四个关键特性特性一:非线...

Visual Studio Community 2022(VS2022)安装图文方法

直接上步骤:1,首先可以下载安装一个VisualStudio安装器,叫做VisualStudioinstaller。这个安装文件很小,很快就安装完成了。2,打开VisualStudioins...

Qt添加MSVC构建套件的方法(qt添加c++11)

前言有些时候,在Windows下因为某些需求需要使用MSVC编译器对程序进行编译,假设我们安装Qt的时候又只是安装了MingW构建套件,那么此时我们该如何给现有的Qt添加一个MSVC构建套件呢?本文以...

Qt为什么站稳c++GUI的top1(qt c)

为什么现在QT越来越成为c++界面编程的第一选择,从事QT编程多年,在这之前做C++界面都是基于MFC。当时为什么会从MFC转到QT?主要原因是MFC开发界面想做得好看一些十分困难,引用第三方基于MF...

qt开发IDE应该选择VS还是qt creator

如果一个公司选择了qt来开发自己的产品,在面临IDE的选择时会出现vs或者qtcreator,选择qt的IDE需要结合产品需求、部署平台、项目定位、程序猿本身和公司战略,因为大的软件产品需要明确IDE...

Qt 5.14.2超详细安装教程,不会来打我

Qt简介Qt(官方发音[kju:t],音同cute)是一个跨平台的C++开库,主要用来开发图形用户界面(GraphicalUserInterface,GUI)程序。Qt是纯C++开...

Cygwin配置与使用(四)——VI字体和颜色的配置

简介:VI的操作模式,基本上VI可以分为三种状态,分别是命令模式(commandmode)、插入模式(Insertmode)和底行模式(lastlinemode),各模式的功能区分如下:1)...

取消回复欢迎 发表评论: