`

条件变量的使用

 
阅读更多
#include <pthread.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
pthread_mutex_t mutex; 
pthread_cond_t cond; 
int cnt = 0; 
void* fun1(void* argv){
	fprintf(stdout, "enter fun1\n");
	pthread_mutex_lock(&mutex);
	while(cnt < 10){
		//执行下面的语句后,mutex会被释放,可以供其他的线程使用
		pthread_cond_wait(&cond, &mutex);
	}
	fprintf(stdout, "cnt is %d\n", cnt);
	pthread_mutex_unlock(&mutex);
	fprintf(stdout, "leave fun1\n");
}
void* fun2(void* argv){
	fprintf(stdout, "enter fun2\n");
	pthread_mutex_lock(&mutex);
	cnt = 10; 
	//唤醒被cond阻塞的线程
	pthread_cond_signal(&cond);
	pthread_mutex_unlock(&mutex);
	fprintf(stdout, "leave fun2\n");
}
int main(){	
	int ret; 
	if(( ret = pthread_mutex_init(&mutex, NULL)) != 0){
		fprintf(stderr, "initialize mutex error. msg:%s\n", strerror(ret));
	}
	if(( ret = pthread_cond_init(&cond, NULL)) != 0){
		fprintf(stderr, "initialize cond error. msg:%s\n", strerror(ret));
	}
	pthread_t p1, p2; 
	if((ret = pthread_create(&p2, NULL, fun2, NULL))){
		fprintf(stderr, "create thread 2 error\n"); 
	}
	if((ret = pthread_create(&p1, NULL, fun1, NULL))){
		fprintf(stderr, "create thread 1 error\n"); 
	}
	pthread_join(p1, NULL);
	pthread_join(p2, NULL);
	return 0; 
}	
 
分享到:
评论

相关推荐

    多线程编程——条件变量使用(Jack_pthread_cond_test.rar)

    多线程编程:条件变量使用。 打包文件包含两个文件:c文件源代码、Makefile文件,运行环境在Ubuntu14.04下,使用自带的gcc编译器,同学们只需将文件夹复制到某一目录下之后在终端执行:1.“make”生成“test”可执行...

    C++多线程中的锁和条件变量使用教程

    C++多线程中的锁和条件变量使用教程 在C++多线程编程中,锁和条件变量是两个非常重要的概念,它们都是用于解决多线程之间的同步和通信问题的。下面我们将详细地介绍锁和条件变量的使用。 一、锁(Mutex) 锁是多...

    linux条件变量简单讲解[归类].pdf

    销毁条件变量使用`pthread_cond_destroy()`函数,但需要注意,只有当没有任何线程正在等待该条件变量时才能执行此操作,否则会返回错误代码EBUSY。 条件变量的两个主要操作是等待和激发。线程等待条件变量有两种...

    多线程之条件变量

    在Java中,条件变量是`java.util.concurrent.locks.Condition`接口的实现,通常与锁(如`ReentrantLock`)一起使用。在C++的`std::condition_variable`库中,也有类似的实现。下面我们将深入探讨条件变量的概念、...

    浅谈Linux条件变量的使用

    以下是一个典型的条件变量使用示例: ```c #include #include #include // 定义条件变量和互斥锁 pthread_cond_t qcond; pthread_mutex_t qlock; int main() { pthread_cond_init(&qcond, NULL); // 初始化...

    Linux互斥锁、条件变量和信号量

    在多线程编程中,确保线程安全是至关重要的,特别是在Linux系统中,为了管理共享资源,Linux提供了互斥锁、条件变量和信号量这三种同步机制。它们都是用于协调多个线程对共享数据的访问,防止数据不一致性和竞态条件...

    线程同步 条件变量

    pthread 条件变量,线程同步

    互斥锁与条件变量详解 疑问全解

    下面,我们将详细解释互斥锁和条件变量的工作机制、使用场景和注意事项。 互斥锁(Mutex) 互斥锁是最基本的同步机制,它用于保护共享资源免受多个线程同时访问的干扰。互斥锁可以是普通锁(PTHREAD_MUTEX_TIMED_...

    线程池与条件变量

    讲述线程池如何创建以及代码的编写,条件变量的使用。

    C++跨平台条件变量和互斥锁封装

    在`ConsoleApplication2`这个项目中,很可能就包含了一个这样的示例,演示了如何在不同操作系统上使用条件变量和互斥锁。 在Windows和Linux中,C++标准库提供的`std::mutex`和`std::condition_variable`已经实现了...

    互斥锁、条件变量、信号量总结

    条件变量通常与互斥锁一起使用,以防止在检查条件和等待之间出现竞态条件。例如,在打印任务的例子中,两个线程通过共享变量、互斥锁和条件变量协同工作,交替打印数字,确保打印的顺序正确。条件变量的应用场景通常...

    c语言跨平台条件变量封装

    条件变量所为一种线程安全对象,在多线程开发中,是有一些使用场景的,比如多个线程协作执行任务,或者生产者消费者模式的实现,都可以使用条件变量来进行线程控制。c语言做多线程开发,实现一个跨平台条件变量量...

    linux无亲缘关系进程间通信(互斥锁+条件变量+共享内存)

    客户端进程则通过连接共享内存,使用互斥锁保护数据,当数据满足预设条件时,服务器进程会发送条件变量信号通知客户端,客户端接收到信号后继续执行。 实现这种通信模式的关键在于正确地管理和同步互斥锁和条件变量...

    linux无亲缘关系间进程同步通信实现(互斥锁+条件变量+共享内存模式)

    本主题将深入探讨如何使用互斥锁、条件变量以及共享内存这三种机制来实现无亲缘关系间进程的同步通信。 1. **互斥锁(Mutex)**: 互斥锁是一种基本的同步原语,用于保护共享资源。当一个进程获取了互斥锁后,其他...

    ODI中变量的使用

    例如,可以在变量中存储筛选条件,然后在接口的映射步骤中使用这些变量,使数据加载步骤根据变量值动态变化。 8. 包中自动刷新变量值: 在ODI的包(Package)中,可以配置步骤自动刷新变量的值。这样,每次包运行...

    浅谈互斥锁为什么还要和条件变量配合使用

    而条件变量通过允许线程阻塞和等待另一个线程发送信号的方法弥补了互斥锁的不足,它常和互斥锁一起配合使用。使用时,条件变量被用来阻塞一个线程,当条件不满足时,线程往往解开相应的互斥锁并等待条件发生变化。...

    kettle8 模拟表输入查询表名,然后在另一个表输入中使用变量使用

    在Kettle8中,模拟表输入查询表名并使用变量是一项常见的数据处理任务,它涉及到工作流中的动态数据源选择和参数化。Kettle8,也称为Pentaho Data Integration (PDI),是一款强大的ETL(提取、转换、加载)工具,...

    linux条件变量简单讲解.pdf

    条件变量通常与互斥锁(mutex)一起使用,以避免竞争条件(Race Condition)和确保线程间的同步。本篇讲解将详细介绍Linux条件变量的基本概念、使用方法及其相关函数。 首先,条件变量是一种线程间通信的同步机制,...

Global site tag (gtag.js) - Google Analytics