多线程编程是一种在计算机程序中同时执行多个线程(子任务)的编程技术,它可以提高程序的并发性和性能。在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语言中的重要编程技术,它允许程序同时执行多个任务,提高了程序的并发性和性能。通过了解线程的创建、退出、传参和返回值,以及线程同步与通信的机制,你可以编写多线程程序来解决各
文章浏览阅读2.4w次,点赞9次,收藏15次。自动包装&自动拆包Integer 是包装类,与int不是一种数据类型,本不能一起做运算,但是java设计了一种功能叫做自动包装。从java5.0版本以后开始提供了自动包装功能,可以简化编码简单理解就是包装类型和基本类型之间可以自动转换类型赋值。自动包装:将基本类型自动包装为包装类型;自动拆包:将包装类型自动转化为基本类型。举个例子:自动包装int m = 2;Inte..._integer加减乘除
文章浏览阅读3.5k次,点赞2次,收藏2次。在HTML5中,新增了两个元素---video元素与audio元素。video元素专门用来播放网络上的视频或电影,而audio元素专门用来播放网络上的音频数据。使用这两个元素,就不在需要使用其他插件了,只需要支持HTML5的浏览器即可。今天,我们在这里就详细的说说video元素它(video)的作用是用于播放视频。它所主要支持的文件格式有webm、ogg、MP4、MP3、WAVE。它的用法..._html5 前端 video 兼容 格式转换插件
文章浏览阅读625次。基本思想:简单学习了一下移植Google的日志包,以备后续跨平台直接使用;首先编译生成静态包,如果需要夸平台需要修改对应的编译器ubuntu@ubuntu:git clone https://github.com/gflags/gflags.gitubuntu@ubuntu:cd gflags/ubuntu@ubuntu:~/gflags$ mkdir buildubuntu@ubuntu:~/gflags/build$ cmake ..ubuntu@ubuntu:~/gflags/bui_clion自动导入包
文章浏览阅读1.7w次。原创: 思齐大神 来源:蚁开源社区很多同学会问,IT行业在中国并不是特别差的行业,而程序员的工资也并不低,但为什么中国的程序员总被称作码农或者说是苦逼的程序员?中国的程序员生活和欧美的有什么不一样?先说两个小段子街边,一对情侣在吵架。女孩对男孩说,“我们分手吧!”男孩沉默半天,开口问道,“我能再说最后一句话吗?”“说吧,婆婆妈妈的。”“我会编程……”“会编程有个屁用啊,现在到处都是会编程的人!”男孩涨红了脸,接着说道,“我会编程……我会变成…童话里,你爱的那个天使……”【程序._码农
文章浏览阅读259次。Java初学者也能看的懂的AQS学习AQS之前,你需要了解以下内容,如果不是很清楚,那么理解本文会有点吃力。(Java初学者得会一下内容)synchronizedCASLock前言synchronized首先我们知道synchronized是Java关键字,上锁释放锁等一切操作都是由JVM控制的。我们只能通过虚拟机的C++才能去研究其底层实现。我们除了判断synchronized是作为方法的修饰符,还是当做同步代码块使用以外,没什么需要我们程序员操作的。cas一种自旋的原子操作,也是J_aqs对接
文章浏览阅读460次。DescriptionSolution首先我们可以知道两个性质:1、路径u-v和路径v-w可以合并为路径u-w;2、路径u1-v1加路径u2-v2和路径u1-v2加路径u2-v1是等价的(就是起始点和终点可以互换) 那么知道这些性质之后就很好做了。我们只用知道每个点多少次做起点和多少次做终点。 我们设f[i]表示满足i子树的需求i上的值要是多少。 那么枚举i的所有儿子,判断a[i]-f[i],_gdoi2018省选模拟树
文章浏览阅读3.3k次。不能删除。看看文件夹下的内容就知道:1、me_tcat:是MyEclipse记录的当前工作空间中的配置,比如当前工作空间中有哪些工程,打开了哪些文件java类,编辑了哪些文件和Java类,MyEclipse会在启动时加载这个文件夹下的内容。如果删除了,再次打开MyEclipse会发现工作空间是空的,需要重新导入工程。2、plugins:当前工作空间用到了哪些IDE插件,和程程序无关_metadata可以删除吗
文章浏览阅读4.1k次。SeetaFace2 Android 平台编译项目地址:https://github.com/seetafaceengine/SeetaFace2SeetaFace2 人脸识别引擎包括了搭建一套全自动人脸识别系统所需的三个核心模块,即:人脸检测模块 FaceDetector、面部关键点定位模块 FaceLandmarker 以及人脸特征提取与比对模块 FaceRecognizer。面部关键点定位支持 5 点 和 81 点定位,两个辅助模块 FaceTracker 和 QualityAssessor 用_seetafacerecognizer2.0.ats
文章浏览阅读3.2w次,点赞4次,收藏34次。1.删除约束语句:alter table 表名 drop constraint 约束名;alter table mz_sf4 drop constraint pk_id1;2.删除主键语句:alter table 表名 drop primary key;alter table mz_sf3 drop primary key;如果出错:ORA-02273:此唯一主键已_oracle删除主键的sql语句
文章浏览阅读989次,点赞9次,收藏13次。这份面试题几乎包含了他在一年内遇到的所有面试题以及答案,甚至包括面试中的细节对话以及语录,可谓是细节到极致,甚至简历优化和怎么投简历更容易得到面试机会也包括在内!也包括教你怎么去获得一些大厂,比如阿里,腾讯的内推名额!某位名人说过成功是靠99%的汗水和1%的机遇得到的,而你想获得那1%的机遇你首先就得付出99%的汗水!你只有朝着你的目标一步一步坚持不懈的走下去你才能有机会获得成功!成功只会留给那些有准备的人!《一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频+实战项目源码》点击传送门即可获取。
文章浏览阅读2k次。关于Vertectorization哪些是正确的( )相对于其他编程模型,sql在大数据领域有哪些好处( )哪些部分适合做codegen( )关于内存计算描述不正确的有( )_vertectorization
文章浏览阅读306次。百度找到了某论坛高人写的java(具体论坛记不清了),直接用来调用,再次非常感谢,基本上实现了我的需求package MD5;import java.util.Scanner;public class ChineseToPinYin {/*** 汉字转拼音缩写** @param str* 要转换的汉字字符串* @return String 拼音缩写*/public Strin..._java生成拼音码