Linux pthread线程怎么创建与使用

Linux pthread线程怎么创建与使用在Linux环境下，线程是一种轻量级的进程，它可以共享进程的资源，如内存、文件描述符等。而pthread库则是Linux下最常用的多线程编程库，它提供了一系列函数来创建、销毁和管理线程。示例代码如下：#include #include void *print_message{char *message;message = ptr;printf;}int main(){pthread_t thread1, thread2;char *message1 = "Thread 1";char *message2 = "Thread 2";int ret1, ret2;// 创建线程1ret1 = pthread_create;if {printf;return -1;}// 创建线程2ret2 = pthread_create;if {printf;return -1;}pthread_join;pthread_join;return 0;}2. 继承父线程创建子线程使用fork函数创建子进程后，子进程会继承父进程的所有资源，包括线程。因此，子进程可以直接调用pthread_create函数来创建新线程。

Linux pthread线程怎么创建与使用

在Linux环境下，线程是一种轻量级的进程，它可以共享进程的资源，如内存、文件描述符等。而pthread库则是Linux下最常用的多线程编程库，它提供了一系列函数来创建、销毁和管理线程。

pthread线程的创建主要有两种方法：

1. 使用pthread_create函数创建线程

pthread_create函数的原型为：

int pthread_create(pthread_t *thread, const pthread_attr_t *attr,

void *(*start_routine) (void *), void *arg);

其中，thread为指向新线程标识符的指针；attr为指向线程属性的指针，如果为NULL，则使用默认属性；start_routine为指向线程函数的指针；arg为传递给线程函数的参数。

示例代码如下：

#include

#include

void *print_message(void *ptr)

{

char *message;

message = (char *) ptr;

printf("%s \n", message);

}

int main()

{

pthread_t thread1, thread2;

char *message1 = "Thread 1";

char *message2 = "Thread 2";

int ret1, ret2;

// 创建线程1

ret1 = pthread_create(&thread1, NULL, print_message, (void*) message1);

if (ret1) {

printf("Error:unable to create thread1, return code:%d\n", ret1);

return -1;

}

// 创建线程2

ret2 = pthread_create(&thread2, NULL, print_message, (void*) message2);

if (ret2) {

printf("Error:unable to create thread2, return code:%d\n", ret2);

return -1;

}

pthread_join(thread1, NULL);

pthread_join(thread2, NULL);

return 0;

}

2. 继承父线程创建子线程

使用fork函数创建子进程后，子进程会继承父进程的所有资源，包括线程。因此，子进程可以直接调用pthread_create函数来创建新线程。

示例代码如下：

#include

#include

#include

#include

void *print_message(void *ptr)

{

char *message;

message = (char *) ptr;

printf("%s \n", message);

}

int main()

{

pid_t pid;

char *message1 = "Thread 1";

char *message2 = "Thread 2";

pid = fork();

if (pid == 0) { // 子进程

pthread_t thread2;

int ret2;

ret2 = pthread_create(&thread2, NULL, print_message, (void*) message2);

if (ret2) {

printf("Error:unable to create thread2, return code:%d\n", ret2);

return -1;

}

pthread_join(thread2, NULL);

} else if (pid > 0) { // 父进程

pthread_t thread1;

int ret1;

ret1 = pthread_create(&thread1, NULL, print_message, (void*) message1);

if (ret1) {

printf("Error:unable to create thread1, return code:%d\n", ret1);

return -1;

}

pthread_join(thread1, NULL);

} else {

printf("Error:fork failed.\n");

return -1;

}

return 0;

}

pthread线程的使用主要涉及以下几个方面：

1. 线程同步

在多线程编程中，线程之间的执行顺序是不确定的，因此可能会出现数据竞争问题。为了避免这种问题，需要使用线程同步技术，如互斥锁、条件变量等。

示例代码如下：

#include

#include

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

int count = 0;

void *produce(void *ptr)

{

while (1) {

pthread_mutex_lock(&mutex);

count++;

printf("Produce: %d\n", count);

if (count == 5) {

pthread_cond_signal(&cond);

}

pthread_mutex_unlock(&mutex);

sleep(1);

}

}

void *consume(void *ptr)

{

while (1) {

pthread_mutex_lock(&mutex);

if (count < 5) {

pthread_cond_wait(&cond, &mutex);

}

printf("Consume: %d\n", count);

count = 0;

pthread_mutex_unlock(&mutex);

sleep(1);

}

}

int main()

{

pthread_t thread1, thread2;

int ret1, ret2;

ret1 = pthread_create(&thread1, NULL, produce, NULL);

if (ret1) {

printf("Error:unable to create thread1, return code:%d\n", ret1);

return -1;

}

ret2 = pthread_create(&thread2, NULL, consume, NULL);

if (ret2) {

printf("Error:unable to create thread2, return code:%d\n", ret2);

return -1;

}

pthread_join(thread1, NULL);

pthread_join(thread2, NULL);

return 0;

}

2