Linux pthread线程怎么创建与使用

 2023-12-25  阅读 3  评论 0

摘要:(图片来源网络,侵删) (图片来源网络,侵删) Linux pthread线程怎么创建与使用 在Linux环境下,线程是一种轻量级的进程,它可以共享进程的资源,如内存、文件描述符等。而pthread库则是Linux下最常用的多线程编程库,它提供了一系列函数来创建、销毁和管理线程。 一、pt

Linux pthread线程怎么创建与使用

(图片来源网络,侵删) (图片来源网络,侵删)

Linux pthread线程怎么创建与使用

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

一、pthread线程的创建

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:%dn", ret1);

return -1;

}

// 创建线程2

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

if (ret2) {

printf("Error:unable to create thread2, return code:%dn", 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:%dn", 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:%dn", ret1);

return -1;

}

pthread_join(thread1, NULL);

} else {

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

return -1;

}

return 0;

}

二、pthread线程的使用

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: %dn", 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

pthread_cond_wait(&cond, &mutex);

}

printf("Consume: %dn", 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:%dn", ret1);

return -1;

}

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

if (ret2) {

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

return -1;

}

pthread_join(thread1, NULL);

pthread_join(thread2, NULL);

return 0;

}

2

版权声明:xxxxxxxxx;

原文链接:https://lecms.nxtedu.cn/yunzhuji/137426.html

标签:linux销毁

发表评论:

验证码

管理员

  • 内容1196553
  • 积分0
  • 金币0
关于我们
lecms主程序为免费提供使用,使用者不得将本系统应用于任何形式的非法用途,由此产生的一切法律风险,需由使用者自行承担,与本站和开发者无关。一旦使用lecms,表示您即承认您已阅读、理解并同意受此条款的约束,并遵守所有相应法律和法规。
联系方式
电话:
地址:广东省中山市
Email:admin@qq.com
注册登录
注册帐号
登录帐号

Copyright © 2022 LECMS Inc. 保留所有权利。 Powered by LECMS 3.0.3

页面耗时0.0135秒, 内存占用356.8 KB, 访问数据库18次