多线程编程是一种在计算机程序中同时执行多个线程(子任务)的编程技术,它可以提高程序的并发性和性能。在C语言中,多线程编程通常通过标准库中的pthread
库来实现。本文将详细介绍C语言中多线程编程的基本概念、线程的创建和管理、线程同步与通信以及一些常见的多线程编程模式。
线程是一个程序内部的执行单元,每个线程都有自己的执行路径和上下文。一个进程可以包含多个线程,这些线程可以并发执行,共享进程的内存空间和资源,但拥有各自的栈空间和寄存器状态。
多线程编程有以下优点:
线程的生命周期包括以下阶段:
在C语言中,多线程编程通常使用pthread
库(POSIX Threads)来实现。pthread
库提供了一组函数和数据结构,用于创建、管理和同步线程。要使用pthread
库,需要在编译时链接-lpthread
标志。
在C语言中,使用pthread_create
函数来创建新线程。以下是pthread_create
函数的基本用法:
#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
:新线程的入口函数,该函数接受一个void*
参数并返回void*
。arg
:传递给start_routine
的参数。下面是一个简单的示例,演示如何创建一个新线程:
#include <stdio.h>
#include <pthread.h>
void *print_hello(void *arg) {
printf("Hello from new thread!\n");
return NULL;
}
int main() {
pthread_t tid; // 线程标识符
pthread_create(&tid, NULL, print_hello, NULL);
pthread_join(tid, NULL); // 等待新线程结束
printf("Main thread: New thread has finished.\n");
return 0;
}
在上面的示例中,pthread_create
函数创建了一个新线程,该线程执行print_hello
函数。pthread_join
函数用于等待新线程的结束。
线程可以通过pthread_exit
函数主动退出,也可以通过从线程函数中返回退出。以下是两种方式的示例:
#include <stdio.h>
#include <pthread.h>
void *exit_thread(void *arg) {
printf("Thread will exit using pthread_exit.\n");
pthread_exit(NULL); // 主动退出线程
}
void *return_thread(void *arg) {
printf("Thread will exit by returning from thread function.\n");
return NULL; // 返回退出线程
}
int main() {
pthread_t tid1, tid2;
pthread_create(&tid1, NULL, exit_thread, NULL);
pthread_create(&tid2, NULL, return_thread, NULL);
pthread_join(tid1, NULL);
pthread_join(tid2, NULL);
printf("Main thread: All threads have finished.\n");
return 0;
}
在上面的示例中,两种方式都可以用来退出线程,但需要注意线程的资源管理,以免出现内存泄漏。
线程的入口函数可以接受一个参数,并返回一个值。要向线程传递参数,可以将参数打包为一个结构体,并通过void*
传递。要从线程函数返回值,可以将返回值作为指针传递给线程函数,并在函数内部修改该指针指向的值。
以下是一个示例,演示如何向线程传递参数并获取返回值:
#include <stdio.h>
#include <pthread.h>
// 结构体用于传递参数和接收返回值
typedef struct {
int a;
int b;
} ThreadParams;
void *add_numbers(void *arg) {
ThreadParams *params = (ThreadParams *)arg;
int result = params->a + params->b;
return (void *)(intptr_t)result; // 将结果作为指针返回
}
int main() {
pthread_t tid;
ThreadParams params = {5, 3};
void *retval; // 存储线程的返回值
pthread_create(&tid, NULL, add_numbers, ¶ms);
pthread_join(tid, &retval); // 获取线程的返回值
int result = (int)(intptr_t)retval; // 将返回值转换为整数
printf("Result: %d\n", result);
return 0;
}
线程在完成任务后可以通过pthread_exit
来正常退出,也可以使用pthread_cancel
函数来取消线程的执行。要注意线程取消可能会引发一些资源管理的问题,因此需要小心使用。
#include <stdio.h>
#include <pthread.h>
void *cancel_thread(void *arg) {
printf("Thread will be canceled.\n");
pthread_cancel(pthread_self()); // 取消当前线程
printf("Thread is still running after cancel.\n");
return NULL;
}
int main() {
pthread_t tid;
pthread_create(&tid, NULL, cancel_thread, NULL);
pthread_join(tid, NULL);
printf("Main thread: Thread has finished.\n");
return 0;
}
在上面的示例中,线程在自身内部调用pthread_cancel
来取消自己的执行。
多个线程访问共享资源时可能导致竞态条件,为了避免竞态条件,可以使用互斥锁(Mutex)。互斥锁允许一个线程在访问共享资源时锁定它,其他线程必须等待解锁后才能访问。
以下是互斥锁的基本用法:
#include <stdio.h>
#include <pthread.h>
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; // 初始化互斥锁
void *increment(void *arg) {
for (int i = 0; i < 1000000; i++) {
pthread_mutex_lock(&mutex); // 锁定互斥锁
// 访问共享资源
pthread_mutex_unlock(&mutex); // 解锁互斥锁
}
return NULL;
}
int main() {
pthread_t tid1, tid2;
pthread_create(&tid1, NULL, increment, NULL);
pthread_create(&tid2, NULL, increment, NULL);
pthread_join(tid1, NULL);
pthread_join(tid2, NULL);
printf("Main thread: All threads have finished.\n");
return 0;
}
在上面的示例中,两个线程分别执行increment
函数,通过互斥锁来保护对共享资源的访问。
条件变量(Condition Variable)用于在线程之间进行通信,它允许一个线程等待另一个线程满足某个条件后再继续执行。通常与互斥锁一起使用。
以下是条件变量的基本用法:
#include <stdio.h>
#include <pthread.h>
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t condition = PTHREAD_COND_INITIALIZER;
void *waiter(void *arg) {
pthread_mutex_lock(&mutex);
printf("Waiter: Waiting for signal...\n");
pthread_cond_wait(&condition, &mutex); // 等待条件变量
printf("Waiter: Received signal. Continuing...\n");
pthread_mutex_unlock(&mutex);
return NULL;
}
void *signaler(void *arg) {
sleep(2); // 等待2秒
printf("Signaler: Signaling...\n");
pthread_cond_signal(&condition); // 发送信号
return NULL;
}
int main() {
pthread_t tid1, tid2;
pthread_create(&tid1, NULL, waiter, NULL);
pthread_create(&tid2, NULL, signaler, NULL);
pthread_join(tid1, NULL);
pthread_join(tid2, NULL);
printf("Main thread: All threads have finished.\n");
return 0;
}
在上面的示例中,waiter
线程等待条件变量,而signaler
线程在2秒后发送信号,唤醒等待线程。
读写锁(Read-Write Lock)用于控制多线程对共享数据的读写访问。多个线程可以同时读取共享数据,但只有一个线程可以写入数据。读写锁可以提高程序的并发性,适用于读多写少的场景。
以下是读写锁的基本用法:
#include <stdio.h>
#include <pthread.h>
pthread_rwlock_t rwlock = PTHREAD_RWLOCK_INITIALIZER;
void *reader(void *arg) {
pthread_rwlock_rdlock(&rwlock); // 读取锁
printf("Reader: Reading data...\n");
pthread_rwlock_unlock(&rwlock); // 解锁
return NULL;
}
void *writer(void *arg) {
pthread_rwlock_wrlock(&rwlock); // 写入锁
printf("Writer: Writing data...\n");
pthread_rwlock_unlock(&rwlock); // 解锁
return NULL;
}
int main() {
pthread_t tid1, tid2;
pthread_create(&tid1, NULL, reader, NULL);
pthread_create(&tid2, NULL, writer, NULL);
pthread_join(tid1, NULL);
pthread_join(tid2, NULL);
printf("Main thread: All threads have finished.\n");
return 0;
}
在上面的示例中,reader
线程获取读取锁,而writer
线程获取写入锁,以模拟多个读取线程和一个写入线程的情况。
生产者-消费者模式是一种常见的多线程编程模式,用于解决生产者线程和消费者线程之间的协作问题。生产者线程生成数据并将其放入缓冲区,而消费者线程从缓冲区中获取数据并进行处理。
以下是一个简单的生产者-消费者示例:
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#define BUFFER_SIZE 5
int buffer[BUFFER_SIZE];
int count = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t full = PTHREAD_COND_INITIALIZER;
pthread_cond_t empty = PTHREAD_COND_INITIALIZER;
void *producer(void *arg) {
for (int i = 0; i < 10; i++) {
sleep(1); // 模拟生产过程
pthread_mutex_lock(&mutex);
while (count == BUFFER_SIZE) {
pthread_cond_wait(&empty, &mutex); // 等待缓冲区非满
}
buffer[count++] = i;
printf("Producer: Produced %d\n", i);
pthread_cond_signal(&full); // 通知消费者缓冲区非空
pthread_mutex_unlock(&mutex);
}
return NULL;
}
void *consumer(void *arg) {
for (int i = 0; i < 10; i++) {
sleep(1); // 模拟消费过程
pthread_mutex_lock(&mutex);
while (count == 0) {
pthread_cond_wait(&full, &mutex); // 等待缓冲区非空
}
int item = buffer[--count];
printf("Consumer: Consumed %d\n", item);
pthread_cond_signal(&empty); // 通知生产者缓冲区非满
pthread_mutex_unlock(&mutex);
}
return NULL;
}
int main() {
pthread_t producer_tid, consumer_tid;
pthread_create(&producer_tid, NULL, producer, NULL);
pthread_create(&consumer_tid, NULL, consumer, NULL);
pthread_join(producer_tid, NULL);
pthread_join(consumer_tid, NULL);
printf("Main thread: All threads have finished.\n");
return 0;
}
在上面的示例中,生产者线程和消费者线程使用互斥锁和条件变量来同步,确保缓冲区的正确访问。
线程池是一种管理线程的机制,它预先创建一组线程并维护一个任务队列。当有任务需要执行时,线程池从队列中获取一个空闲线程并将任务分配给它。
以下是一个简单的线程池示例:
#include <stdio.h>
#include <pthread.h>
#define THREAD_COUNT 4
#define TASK_COUNT 10
typedef struct {
int task_id;
} Task;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t task_available = PTHREAD_COND_INITIALIZER;
void *worker(void *arg) {
while (1) {
pthread_mutex_lock(&mutex);
while (/* 任务队列为空 */) {
pthread_cond_wait(&task_available, &mutex);
}
// 从任务队列中获取任务
// 执行任务
pthread_mutex_unlock(&mutex);
}
return NULL;
}
int main() {
pthread_t threads[THREAD_COUNT];
// 创建线程池
for (int i = 0; i < THREAD_COUNT; i++) {
pthread_create(&threads[i], NULL, worker, NULL);
}
// 向线程池添加任务
for (int i = 0; i < TASK_COUNT; i++) {
Task task = {i};
pthread_mutex_lock(&mutex);
// 将任务添加到队列
pthread_cond_signal(&task_available); // 通知线程池有任务可用
pthread_mutex_unlock(&mutex);
}
// 等待线程池中的线程执行完所有任务
for (int i = 0; i < THREAD_COUNT; i++) {
pthread_join(threads[i], NULL);
}
printf("Main thread: All tasks have been completed.\n");
return 0;
}
在上面的示例中,线程池由多个线程组成,它们等待任务队列中的任务并执行。主线程向线程池添加任务,并等待线程池中的线程执行完所有任务。
多线程编程容易引发竞态条件(Race Condition),即多个线程同时访问共享资源,导致不可预测的结果。为了避免竞态条件,需要使用互斥锁等同步机制。
死锁(Deadlock)是多线程编程中常见的问题,它发生在多个线程互相等待对方释放资源的情况下。要避免死锁,需要小心设计线程的同步和资源管理策略。
多线程共享数据时需要注意数据的一致性和完整性。使用互斥锁、读写锁等机制来保护共享数据,确保线程安全。
多线程编程可以提高程序的并发性和性能,但也可能引入线程管理开销。要权衡性能和扩展性,避免创建过多线程。
多线程编程是C语言中的重要编程技术,它允许程序同时执行多个任务,提高了程序的并发性和性能。通过了解线程的创建、退出、传参和返回值,以及线程同步与通信的机制,你可以编写多线程程序来解决各
文章浏览阅读1.6k次。安装配置gi、安装数据库软件、dbca建库见下:http://blog.csdn.net/kadwf123/article/details/784299611、检查集群节点及状态:[root@rac2 ~]# olsnodes -srac1 Activerac2 Activerac3 Activerac4 Active[root@rac2 ~]_12c查看crs状态
文章浏览阅读1.3w次,点赞45次,收藏99次。我个人用的是anaconda3的一个python集成环境,自带jupyter notebook,但在我打开jupyter notebook界面后,却找不到对应的虚拟环境,原来是jupyter notebook只是通用于下载anaconda时自带的环境,其他环境要想使用必须手动下载一些库:1.首先进入到自己创建的虚拟环境(pytorch是虚拟环境的名字)activate pytorch2.在该环境下下载这个库conda install ipykernelconda install nb__jupyter没有pytorch环境
文章浏览阅读5.2k次,点赞19次,收藏28次。选择scoop纯属意外,也是无奈,因为电脑用户被锁了管理员权限,所有exe安装程序都无法安装,只可以用绿色软件,最后被我发现scoop,省去了到处下载XXX绿色版的烦恼,当然scoop里需要管理员权限的软件也跟我无缘了(譬如everything)。推荐添加dorado这个bucket镜像,里面很多中文软件,但是部分国外的软件下载地址在github,可能无法下载。以上两个是官方bucket的国内镜像,所有软件建议优先从这里下载。上面可以看到很多bucket以及软件数。如果官网登陆不了可以试一下以下方式。_scoop-cn
文章浏览阅读4.5k次,点赞2次,收藏3次。首先要有一个color-picker组件 <el-color-picker v-model="headcolor"></el-color-picker>在data里面data() { return {headcolor: ’ #278add ’ //这里可以选择一个默认的颜色} }然后在你想要改变颜色的地方用v-bind绑定就好了,例如:这里的:sty..._vue el-color-picker
文章浏览阅读640次。基于芯片日益增长的问题,所以内核开发者们引入了新的方法,就是在内核中只保留函数,而数据则不包含,由用户(应用程序员)自己把数据按照规定的格式编写,并放在约定的地方,为了不占用过多的内存,还要求数据以根精简的方式编写。boot启动时,传参给内核,告诉内核设备树文件和kernel的位置,内核启动时根据地址去找到设备树文件,再利用专用的编译器去反编译dtb文件,将dtb还原成数据结构,以供驱动的函数去调用。firmware是三星的一个固件的设备信息,因为找不到固件,所以内核启动不成功。_exynos 4412 刷机
文章浏览阅读2w次,点赞24次,收藏42次。Linux系统配置jdkLinux学习教程,Linux入门教程(超详细)_linux配置jdk
文章浏览阅读3.3k次,点赞5次,收藏19次。xlabel('\delta');ylabel('AUC');具体符号的对照表参照下图:_matlab微米怎么输入
文章浏览阅读119次。顺序读写指的是按照文件中数据的顺序进行读取或写入。对于文本文件,可以使用fgets、fputs、fscanf、fprintf等函数进行顺序读写。在C语言中,对文件的操作通常涉及文件的打开、读写以及关闭。文件的打开使用fopen函数,而关闭则使用fclose函数。在C语言中,可以使用fread和fwrite函数进行二进制读写。 Biaoge 于2024-03-09 23:51发布 阅读量:7 ️文章类型:【 C语言程序设计 】在C语言中,用于打开文件的函数是____,用于关闭文件的函数是____。
文章浏览阅读3.4k次,点赞2次,收藏13次。跟随鼠标移动的粒子以grid(SOP)为partical(SOP)的资源模板,调整后连接【Geo组合+point spirit(MAT)】,在连接【feedback组合】适当调整。影响粒子动态的节点【metaball(SOP)+force(SOP)】添加mouse in(CHOP)鼠标位置到metaball的坐标,实现鼠标影响。..._touchdesigner怎么让一个模型跟着鼠标移动
文章浏览阅读178次。项目运行环境配置:Jdk1.8 + Tomcat7.0 + Mysql + HBuilderX(Webstorm也行)+ Eclispe(IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持)。项目技术:Springboot + mybatis + Maven +mysql5.7或8.0+html+css+js等等组成,B/S模式 + Maven管理等等。环境需要1.运行环境:最好是java jdk 1.8,我们在这个平台上运行的。其他版本理论上也可以。_基于java技术的停车场管理系统实现与设计
文章浏览阅读3.5k次。前言对于MediaPlayer播放器的源码分析内容相对来说比较多,会从Java-&amp;gt;Jni-&amp;gt;C/C++慢慢分析,后面会慢慢更新。另外,博客只作为自己学习记录的一种方式,对于其他的不过多的评论。MediaPlayerDemopublic class MainActivity extends AppCompatActivity implements SurfaceHolder.Cal..._android多媒体播放源码分析 时序图
文章浏览阅读2.4k次,点赞41次,收藏13次。java 数据结构与算法 ——快速排序法_快速排序法