Wie werden Linux-Threads erstellt?

Das Konzept und die Implementierung von Threads

Ein Thread ist eine Ausführungssequenz oder ein Ausführungspfad innerhalb eines Prozesses. Ein Prozess kann mehrere Threads enthalten.

• Aus Sicht der Ressourcenzuweisung ist der Prozess die Grundeinheit der Ressourcenzuweisung durch das Betriebssystem.

• Aus Sicht der Ressourcenplanung ist Thread die kleinste Einheit der Ressourcenplanung und die kleinste Einheit der Programmausführung.

Ausführungssequenz ist ein Satz geordneter Anweisungen – eine Funktion.

Ein Thread ist eine Ausführungssequenz innerhalb eines Prozesses. Ein Prozess verfügt über mindestens einen Thread, der als Hauptthread bezeichnet wird. (Die Ausführungssequenz wird durch die Hauptmethode dargestellt.) Sie können über die Thread-Bibliothek weitere Threads erstellen eine Aufgabe, die sie ausführen möchte) Funktion), wird der erstellte Thread als Funktionsthread bezeichnet.

Wie Threads implementiert werden

• Threads auf Kernelebene (Threads werden direkt vom Kernel erstellt und verwaltet. Obwohl der Erstellungsaufwand hoch ist, können Multiprozessorressourcen genutzt werden)

• Benutzerebene Threads (Threads werden direkt vom Kernel erstellt und verwaltet) Die Implementierung von Threads erfolgt im Benutzermodus und kann vom Kernel nicht erkannt werden. Der Erstellungsaufwand ist gering und die Ressourcen von Multiprozessoren können nicht erkannt werden verwendet)

• Threads auf gemischten Ebenen (durch die Kombination der beiden oben genannten Methoden implementiert, können Sie die Ressourcen des Multiprozessors nutzen, um mehr Threads im Benutzerbereich zu erstellen und so Threads im Kernelbereich zuzuordnen, viele-zu-viele). , N:M (N>>M))

Linux Die Art und Weise, wie das System Multithreading implementiert

Der Mechanismus von Linux zur Implementierung von Threads ist sehr einzigartig.

Aus Sicht des Kernels gibt es kein Thread-Konzept.

Linux implementiert alle Threads als Prozesse. Der Kernel bereitet keine speziellen Planungsalgorithmen vor und definiert keine speziellen Datenstrukturen zur Darstellung von Threads.

Stattdessen wird ein Thread einfach als Prozess betrachtet, der bestimmte Ressourcen mit anderen Prozessen teilt.

Jeder Thread hat seine eigene einzigartige task_struct, sodass er im Kernel wie ein gewöhnlicher Prozess aussieht (der Thread teilt nur bestimmte Ressourcen, wie z. B. den Adressraum, mit einigen anderen Prozessen).

Threads und Prozesse Der Unterschied

• Der Prozess ist die kleinste Einheit der Ressourcenzuweisung, und der Thread ist die kleinste Einheit der Programmausführung.

• Die Effizienz des Wechsels zwischen Threads ist höher als die des Wechsels zwischen Prozessen.

• Der Prozess hat seine eigenen Jedes Mal, wenn ein Prozess gestartet wird, weist das System ihm einen Adressraum zu und erstellt eine Datentabelle, um das Codesegment, das Stapelsegment und das Datensegment zu verwalten der gleiche Adressraum zum Teilen von Daten;

• Erstellen Sie einen Thread. Weniger Overhead als ein Prozess.

• Threads belegen viel weniger Ressourcen als Prozesse.

• Die Kommunikation zwischen Threads ist bequemer. Die Kommunikation zwischen Threads muss über Kommunikation (IPC) erfolgen Der gegenseitige Ausschluss ist ein schwieriger Punkt.)

• Der Tod eines Prozesses hat keine Auswirkungen auf den anderen Prozess (aufgrund des unabhängigen Adressraums sind Multithread-Programme schwieriger zu warten). . Wenn der Prozess stirbt, stirbt der gesamte Prozess (aufgrund des gemeinsam genutzten Adressraums). Der Prozess hat einen hohen Ressourcenschutz, einen hohen Overhead und eine relativ geringe Effizienz Der Overhead ist gering und die Effizienz hoch. , entsperren]

• Bedingungen [Erstellen, zerstören, auslösen, senden, warten]

Nutzung der Thread-Bibliothek

1. Einen Thread erstellen

• #include<phread.h>
  
  int pthread_create(pthread_t *id , pthread_attr_t *attr, void(*fun)(void*), void *arg);

• id: Übergeben Sie die Adresse einer Variablen vom Typ pthread_t. Nach erfolgreicher Erstellung wird sie verwendet, um die TID des neu erstellten Threads abzurufen

• attr: Das Attribut des angegebenen Threads verwendet NULL by Standard

fun: Die Adresse der Thread-Funktion

arg: An die Thread-Funktion übergebene Parameter

• Rückgabewert id ：传递一个pthread_t类型的变量的地址，创建成功后，用来获取新创建的线程的TID

• attr：指定线程的属性 默认使用NULL

• fun：线程函数的地址

• arg：传递给线程函数的参数

• 返回值，成功返回0，失败返回错误码

多线程代码示例

#include<stdio.h>
#include<stdlib.h>
#include<assert.h>
#include<string.h>
#include<unistd.h>

#include<pthread.h>

//声明一个线程函数
void *fun(void *);

int main()
{
	printf("main start\n");

	pthread_t id;
	//创建函数线程，并且指定函数线程要执行的函数
	int res = pthread_create(&id,NULL,fun,NULL);
	assert(res == 0);

	//之后并发运行
	int i = 0;	
	for(; i < 5; i++)
	{
		printf("main running\n");
		sleep(1);
	}

	printf("main over\n");
	exit(0);
}

//定义线程函数
void* fun(void *arg)
{
	printf("fun start\n");

	int i = 0;
	for(; i < 3;i++)
	{
		printf("fun running\n");
		sleep(1);
	}

	printf("fun over\n");
}

gcc编译代码时报`undifined reference to xxxxx错误，都是因为程序中调用了一些方法，但是没有连接该方法所在的文件，例如下面的情况：

连接库文件编译成功并执行，这一点在帮助手册中也有提示：Compile and link with -pthread, Erfolg kehrt zurück 0, Fehler gibt Fehlercode zurück

🎜🎜🎜🎜Beispiel für einen Multithread-Code 🎜🎜

#include<stdio.h>
#include<stdlib.h>
#include<assert.h>
#include<string.h>
#include<unistd.h>

#include<pthread.h>

void *fun(void *);

int main()
{
	printf("main start\n");

	int a = 10;
	
	pthread_t id;
	int res = pthread_create(&id,NULL,fun,(void*)a);
	assert(res == 0);

	int i = 0;	
	for(; i < 5; i++)
	{
		printf("main running\n");
		sleep(1);
	}

	printf("main over\n");
	exit(0);
}


void* fun(void *arg)
{
	int b = (int)arg;
	printf("b == %d\n",b);
}

🎜gcc Beim Kompilieren des Codes tritt ein Fehler „undifizierter Verweis auf xxxxx“ auf, weil einige Methoden im Programm aufgerufen werden, die Datei jedoch nicht Die Methode ist nicht verbunden. Zum Beispiel die folgende Situation: 🎜🎜

比较两次运行的结果发现前三条执行语句时一样的

结论

• 创建线程并执行线程函数，和调用函数是完全不同的概念。

• 主线程和函数线程是并发执行的。

• 线程提前于主线程结束时，不会影响主线程的运行

• 主线程提前于线程结束时，整个进程都会结束，其他线程也会结束

• 创建函数线程后，哪个线程先被执行是有操作系统的调度算法和机器环境决定。

函数线程在主线程结束后也随之退出，原因：主线程结束时使用的是exit方法，这个方法结束的是进程。

然而修改代码为：pthread_exit(NULL);此时主线程结束，函数线程会继续执行直至完成。即便如此，我们还是不推荐大家手动结束主线程，我们更喜欢让主线程等待一会。

给线程函数传参

①值传递

将变量的值直接转成void*类型进行传递

因为线程函数接受的是一个void*类型的指针，只要是指针，32位系统上都是4个字节，值传递就只能传递小于或等于4字节的值。

代码示例

#include<stdio.h>
#include<stdlib.h>
#include<assert.h>
#include<string.h>
#include<unistd.h>

#include<pthread.h>

void *fun(void *);

int main()
{
	printf("main start\n");

	int a = 10;
	
	pthread_t id;
	int res = pthread_create(&id,NULL,fun,(void*)a);
	assert(res == 0);

	int i = 0;	
	for(; i < 5; i++)
	{
		printf("main running\n");
		sleep(1);
	}

	printf("main over\n");
	exit(0);
}


void* fun(void *arg)
{
	int b = (int)arg;
	printf("b == %d\n",b);
}

②地址传递

将变量（所有类型）的地址强转成void*类型进行传递，就和在普通函数调用传递变量的地址相似。

主线程和函数线程通过这个地址就可以共享地址所指向的空间。

一个进程内的所有线程是共享这个进程的地址空间。

多线程下进程的4G虚拟地址空间

一个进程内的所有线程对于全局数据，静态数据，堆区空间都是共享的。

线程之间传递数据很简单，但是随之带来的问题就是线程并发运行时无法保证线程安全。

代码示例

#include<stdio.h>
#include<stdlib.h>
#include<assert.h>
#include<string.h>
#include<unistd.h>

#include<pthread.h>

int gdata = 10; //.data

void *fun(void *);

int main()
{
	int *ptr = (int *)malloc(4);//.heap
    *ptr = 10;
	
	pthread_t id;
	int res = pthread_create(&id,NULL,fun,(void*)ptr);
	assert(res == 0);

    sleep(2);//等待两秒，保证函数线程已经讲数据修改

	printf("main : gdata == %d\n",gdata);
    printf("main : *ptr = %d\n",*ptr);

	exit(0);
}


void *fun(void *arg)
{
	int *p = (int*)arg;

    gdata = 20000;
    *p = 20;

	printf("fun over\n");
}

线程库中的其他方法

线程退出的三种方式：

• 线程从执行函数返回，返回值是线程的退出码；

• 线程被同一进程的其他线程取消；

• 调用pthread_exit（）函数退出；

等待线程终止

int pthread_join(pthread_t thread, void **retval);
args:
    pthread_t thread: 被连接线程的线程号，该线程必须位于当前进程中，而且不得是分离线程
    void **retval :该参数不为NULL时，指向某个位置 在该函数返回时，将该位置设置为已终止线程的退出状态
    return:
    线程连接的状态，0是成功，非0是失败

当A线程调用线程B并 pthread_join() 时，A线程会处于阻塞状态，直到B线程结束后，A线程才会继续执行下去。当 pthread_join() 函数返回后，被调用线程才算真正意义上的结束，它的内存空间也会被释放（如果被调用线程是非分离的）。

这里有三点需要注意：

• 系统仅释放系统空间，你需要手动清除程序分配的空间，例如由 malloc() 分配的空间。

• 2.一个线程只能被一个线程所连接。

• 3.被连接的线程必须是非分离的，否则连接会出错。所以可以看出pthread_join()有两种作用：1-用于等待其他线程结束：当调用 pthread_join() 时，当前线程会处于阻塞状态，直到被调用的线程结束后，当前线程才会重新开始执行。2-对线程的资源进行回收：如果一个线程是非分离的（默认情况下创建的线程都是非分离）并且没有对该线程使用 pthread_join() 的话，该线程结束后并不会释放其内存空间，这会导致该线程变成了“僵尸线程”。

等待指定的子线程结束

• 等待thread（）指定的线程退出，线程未退出时，该方法阻塞

• result接收thread线程退出时，指定退出信息

int pthread_join(pthread_t id,void **result)//调用这个方法的线程会阻塞，直到等待线程结束

代码演示：

#include<stdio.h>
#include<stdlib.h>
#include<assert.h>
#include<string.h>
#include<unistd.h>

#include<pthread.h>

int main()
{
	printf("main start\n");

	pthread_t id;
	int res = pthread_create(&id,NULL,fun,NULL);
	assert(res == 0);

	//之后并发运行
	int i = 0;	
	for(; i < 5; i++)
	{
		printf("main running\n");
		sleep(1);
	}
	
	char *s = NULL;
	pthread_join(id,(void **)&s);
	printf("join : s = %s\n",s);
	
	exit(0);
}

//定义线程函数
void* fun(void *arg)
{
	printf("fun start\n");

	int i = 0;
	for(; i < 10;i++)
	{
		printf("fun running\n");
		sleep(1);
	}

	printf("fun over\n");

	pthread_exit("fun over");//将该字符常量返回给主线程
}

此时，主线程完成五次输出，就会等待子线程结束，阻塞等待，子线程结束后，最后，主线程打印join：s = fun over

关于exit和join的一些详细说明：

• 线程自己运行结束，或者调用pthread_exit结束，线程都会释放自己独有的空间资源；

• 若线程是非分离的，线程会保留线程ID号，直到其他线程通过joining这个线程确认其已经死亡，join的结果是joining线程得到已终止线程的退出状态，已终止线程将消失；

• 若线程是分离的，不需要使用pthread_exit（），线程自己运行结束，线程结束就会自己释放所有空间资源（包括线程ID号）；

• 子线程最终一定要使用pthread_join（）或者设置为分离线程来结束线程，否则线程的资源不会被完全释放（使用取消线程功能也不能完全释放）；

• 主线程运行pthrea_exit()，会结束主线程，但是不会结束子线程；

• 主线程结束，则整个程序结束，所以主线程最好使用pthread_join函数等待子线程结束，使用该函数一个线程可以等待多个线程结束；

• 使用pthread_join函数的线程将会阻塞，直到被join的函数线程结束，该函数返回，但是它对被等待终止的线程运行没有影响；

• 如果子线程使用exit()则可以结束整个进程；

线程属性

线程具有的属性可以在线程创建的时候指定；

——pthread_create()函数的第二个参数(pthread_attr_t *attr)表示线程的属性，在以前的例子中将其值设为NULL,也就是采用默认属性，线程的多项属性都是可以修改的，这些属性包括绑定属性，分离属性，堆栈属性，堆栈大小，优先级。

系统默认的是非绑定，非分离，缺省1M的堆栈以及父子进程优先级相同

线程结构如下：

typedef struct
{
    int             detachstate;     //线程的分离状态
    int             schedpolicy;    //线程调度策略
    struct sched_param  schedparam; //线程的调度参数
    int             inheritsched;   //线程的继承性
    int             scope;      //线程的作用域
    size_t          guardsize;  //线程栈末尾的警戒缓冲区大小
    int             stackaddr_set; //线程的栈设置
    void*           stackaddr;  //线程栈的位置
    size_t          stacksize;  //线程栈的大小
} pthread_attr_t;

每一个属性都有对应的一些函数，用于对其进行查看和修改，下面分别介绍：

线程属性初始化

初始化和去初始化分别对应于如下的两个函数：

#include <pthread.h>

①int pthread_attr_init(pthread_attr_t *attr);
②it pthread_attr_destroy(pthread_attr_t *attr);

①功能：

• 初始化线程属性函数，注意：应先初始化线程属性，再pthread_create创建线程

参数：

• attr：线程属性结构体

返回值：

• 成功：0

• 失败：-1

②功能：

• 销毁线程属性所占用的资源函数

参数：

• attr：线程属性结构体

返回值：

• 成功：0

• 失败：-1

线程分离

线程的分离状态决定一个线程以什么样的方式来终止自己，这个在之前我们也说过了。

• 默认状态下，线程是非分离状态，意味着原有的线程会等待所创建的线程结束。只有在pthread_join()函数返回后，才能释放创建的线程占用的系统资源，也才能视作该线程终止。

• 若线程运行结束且无其他线程阻塞等待，则该线程处于分离状态，此时系统资源将立即被释放。应该根据自己的需要，选择适当的分离状态。

相关API如下：

#include <pthread.h>

int pthread_attr_setdetachstate(pthread_attr_t *attr, int detachstate);

功能：设置线程分离状态

参数：

• attr：已初始化的线程属性

• detachstate： 分离状态

PTHREAD_CREATE_DETACHED（分离线程）

PTHREAD_CREATE_JOINABLE（非分离线程）

返回值：

• 成功：0

• 失败：非0

int pthread_attr_getdetachstate(const pthread_attr_t *attr, int *detachstate);

功能：获取线程分离状态

参数：

• attr：已初始化的线程属性detachstate： 分离状态

PTHREAD_CREATE_DETACHED（分离线程）

PTHREAD _CREATE_JOINABLE（非分离线程）

返回值：

• 成功：0

• 失败：非0

注意：

Wenn ein Thread als getrennter Thread festgelegt ist und die Ausführungsgeschwindigkeit des Threads zu diesem Zeitpunkt sehr hoch ist, wird er wahrscheinlich beendet, bevor pthread_create zurückkehrt. Nach der Beendigung werden die Thread-Nummer und die Systemressourcen übergeben zu anderen Threads, sodass Sie beim Aufrufen von create die falsche Thread-Nummer erhalten. Daher müssen Sie einige Synchronisierungsmaßnahmen ergreifen. Sie können die Funktion pthread_cond_timedwait im erstellten Thread aufrufen, den Thread eine Weile warten lassen und genügend Zeit für die Funktion lassen pthread_create zum Zurückgeben und Festlegen einer Wartezeit. Dies ist eine häufig verwendete Methode in der Multithread-Programmierung. Vermeiden Sie die Verwendung von Funktionen wie wait(), da diese den gesamten Prozess in den Ruhezustand versetzen und keine Thread-Synchronisierungsprobleme lösen.

Das obige ist der detaillierte Inhalt vonWie werden Linux-Threads erstellt?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!