Linux系统编程——多线程实现多任务

概述

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

就像每个进程都有一个进程号一样,每个线程也有一个线程号。进程号在整个系统中是唯一的,但线程号不同,线程号只在它所属的进程环境中有效。进程号用 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;
}

运行结果如下:

本教程示例代码下载请点此链接。

时间: 2024-10-29 08:14:32

Linux系统编程——多线程实现多任务的相关文章

Linux系统编程@多线程编程(二)

线程的操作 线程标识 线程的ID表示数据类型:pthread_t (内核中的实现是unsigned long/unsigned int/指向pthread结构的指针(不可移植)几种类型) 1.对两个线程ID进行比较 #include <pthread.h> int pthread_equal(pthread_t tid1, pthread tid2); //返回值:若相等则返回非0值,不相等返回0 2.获取自身的线程id #include <pthread.h> pthread_t

Linux系统编程@多线程编程

多线程编程 操作系统原理概念 时间片 进程状态 上下文: 对进程来说,就是进程的执行环境,具体就是各个变量和数据,包括所有的寄存器变量.打开的文件.内存信息等. 进程的写时复制:由于一般 fork后面都接着exec,所以,现在的 fork都在用写时复制的技术,顾名思意,就是,数据段,堆,栈,一开始并不复制,由父,子进程共享,并将这些内存设置为只读.直到父,子进程一方尝试写这些区域,则内核才为需要修改的那片内存拷贝副本.这样做可以提高 fork的效率. 线程函数的可重入性:所谓“重入”,常见的情况

Linux系统编程@多线程与多进程GDB调试

博客内容参考自 http://www.cnblogs.com/xuxm2007/archive/2011/04/01/2002162.html http://blog.csdn.net/pbymw8iwm/article/details/7876797 gdb手册(调试多个程序章节+调试多线程进程章节) GDB多线程调试 基本命令 info threads  显示当前可调试的所有线程,每个线程会有一个GDB为其分配的ID,后面操作线程的时候会用到这个ID. 前面有*的是当前调试的线程. thre

Linux系统编程之进程

前一段时间对文件I/O的基本操作基本操作做了总结,今天这里继续按照我的理解对linux系统编程的进程操作进行总结. 首先我们先理解几个概念:程序.进程.线程. 所谓程序,就是计算机指令的集合,它以文件的形式存储在磁盘上,进程是一个程序在其自身的地址空间中的一次执行活动.而线程进程内的一个执行单元,也是进程内的可调度实体.说完这个不知道大家理解了吗?反正我第一次听到这个概念以后看到的时候可以明白过后就忘记了,现在我给大家举一个例子帮助大家理解,大家都看电视剧吧,所谓程序,就是一个剧本,像什么<西游

LINUX系统编程 由REDIS的持久化机制联想到的子进程退出的相关问题

19:22:01 2014-08-27 引言: 以前对wait waitpid 以及exit这几个函数只是大致上了解,但是看REDIS的AOF和RDB 2种持久化时 均要处理子进程运行完成退出和父进程需要做的什么事情,所以特定看了UNIX环境编程和LINUX系统编程这2本书 重新梳理下整个要点. 内容: 一般而言: 如果程序类似于下面的情况: if((pid=fork())==0) { dochildtthing(); exit(0); } else if(pid>0) { dofathertt

Linux系统编程-setitimer函数

功能:linux系统编程中,setitimer是一个经常被使用的函数,可用来实现延时和定时的功能. 头文件:sys/time.h 函数原型: int setitimer(int which, const struct itimerval *new_value, struct itimerval *old_value); 参数含义: 1.which参数用来设置定时器类型,可选的值为 (1)ITIMER_REAL : 设置定时器以系统真实所花费的时间来计时,运行指定时间后发送SIGALRM信号. (

Linux系统编程笔记

写在开篇:出于对未来职业规划的考虑(其实还是一团糟),制定了一个基本的学习方向,那就是从系统编程学习API慢慢的深入内核,这是一个比较成熟的学习路线.所以从本篇开始,在这段时间会陆续记录Linux系统编程的学习笔记,除了供学习之余复习只用,同时也期望能记录初入职场摸爬滚打的第一个3年. 第一章 文件I/O 文件访问的基本调用一般是 read()和write(),但是在访问文件之前,要做的是一项很重要的工作就是:打开,没错!通过调用 open()或create()实现 #include <sys/

Linux系统编程@进程通信(一)

进程间通信概述 需要进程通信的原因: 数据传输 资源共享 通知事件 进程控制 Linux进程间通信(IPC)发展由来 Unix进程间通信 基于System V进程间通信(System V:UNIX系统的一个分支) POSIX进程间通信(POSIX:可移植操作系统接口,为了提高UNIX环境下应用程序的可移植性.很多其他系统也支持POSIX标准(如:DEC OpenVMS和Windows).) 现在Linux使用的进程间通信方式包括: 管道(pipe).有名管道(FIFO) 信号(signal) 消

linux系统编程之管道(一):匿名管道(pipe)

原文地址:http://www.cnblogs.com/mickole/p/3192210.html 一,什么是管道 管道是Linux支持的最初Unix IPC形式之一,具有以下特点: 管道是半双工的,数据只能向一个方向流动:需要双方通信时,需要建立起两个管道: 只能用于父子进程或者兄弟进程之间(具有亲缘关系的进程): 单独构成一种独立的文件系统:管道对于管道两端的进程而言,就是一个文件,但它不是普通的文件,它不属于某种文件系统,而是自立门户,单独构成一种文件系统,并且只存在与内存中. 数据的读