美文网首页
C++多线程编程和同步机制:详解和实例演示

C++多线程编程和同步机制:详解和实例演示

作者: 小万哥 | 来源:发表于2023-05-11 00:12 被阅读0次

C++中的多线程编程和同步机制使得程序员可以利用计算机的多核心来提高程序的运行效率和性能。本文将介绍多线程编程和同步机制的基本概念和使用方法。

多线程编程基础

在C++中,使用<thread>库来创建和管理线程。线程可以通过函数、成员函数或者Lambda表达式来实现。以下是一个使用Lambda表达式来创建线程的例子:

#include <thread>
#include <iostream>

int main() {
    std::thread t([](){
        std::cout << "Hello from thread " << std::this_thread::get_id() << std::endl;
    });
    t.join();
    return 0;
}

[data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw==](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw==)

上述代码创建了一个线程并输出了该线程的ID。在创建线程时,需要将线程函数作为参数传递给std::thread。在上述例子中,我们使用了Lambda表达式来定义线程函数,该表达式会输出一行文本。

同步机制

多线程编程中最常见的问题是数据竞争和死锁。为了避免这些问题,我们需要使用同步机制来控制线程的访问。

互斥量

互斥量是C++中最常用的同步机制之一。互斥量可以保证同一时间只有一个线程可以访问共享资源。以下是一个使用互斥量来保护共享资源的例子:

#include <thread>
#include <mutex>
#include <iostream>

std::mutex mtx;

void thread_func() {
    mtx.lock();
    std::cout << "Hello from thread " << std::this_thread::get_id() << std::endl;
    mtx.unlock();
}

int main() {
    std::thread t1(thread_func);
    std::thread t2(thread_func);
    t1.join();
    t2.join();
    return 0;
}

[data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw==](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw==)

上述代码创建了两个线程,并使用互斥量来保护共享资源。在线程函数中,我们先调用mtx.lock()函数来锁定互斥量,然后访问共享资源,最后再调用mtx.unlock()函数来释放互斥量。在上述例子中,我们使用了两个线程来访问共享资源,但是只有一个线程可以访问该资源。这是因为在一个线程访问共享资源时,该资源会被锁定,其他线程无法访问该资源,直到该线程释放互斥量为止。

条件变量

条件变量是C++中另一个常用的同步机制。条件变量可以让线程在某些条件满足时才继续执行,否则就等待。以下是一个使用条件变量来同步线程的例子:

#include <thread>
#include <mutex>
#include <condition_variable>
#include <iostream>

std::mutex mtx;
std::condition_variable cv;
bool ready = false;

void consumer() {
    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, [](){ return ready; });
    std::cout << "Hello from consumer thread " << std::this_thread::get_id() << std::endl;
}

void producer() {
    std::this_thread::sleep_for(std::chrono::seconds(1));
    ready = true;
    cv.notify_one();
}

int main() {
    std::thread t1(consumer);
    std::thread t2(producer);
    t1.join();
    t2.join();
    return 0;
}

[data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw==](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw==)

上述代码创建了两个线程,一个生产者线程和一个消费者线程。生产者线程在1秒后将ready变量设置为true,然后通知消费者线程继续执行。消费者线程等待条件变量cv,直到ready变量的值为true为止。在该例子中,我们使用了条件变量来同步生产者和消费者线程。

结论

多线程编程和同步机制是C++中非常重要的主题。本文介绍了多线程编程的基本概念和使用方法,以及互斥量和条件变量等常用的同步机制。希望这篇文章对你有所帮助。

相关文章

  • 8-synchronized同步机制详解

    synchronized 同步机制详解 虽然多线程编程极大地提高了效率,但是也会带来一定的隐患。比如说两个线程同时...

  • JVM系列之:对象的锁状态和同步

    简介 锁和同步是java多线程编程中非常常见的使用场景。为了锁定多线程共享的对象,Java需要提供一定的机制来实现...

  • JVM系列之:对象的锁状态和同步

    简介 锁和同步是java多线程编程中非常常见的使用场景。为了锁定多线程共享的对象,Java需要提供一定的机制来实现...

  • Python 3 多线程编程

    本文主要基于python 3.5实现多线程编程 1. 创建多线程 2. 多线程间的同步,lock机制 3. que...

  • ReentrantLock和监视器锁的选择

    在Java多线程编程中,我们经常过加锁的机制来保证线程同步。以Synchronized关键字为实现方式的监视器锁和...

  • C++: 多线程同步机制

    C++生产者消费者 基于锁和条件变量的同步机制 基于pipe的同步机制 基于变量的同步机制,在面对select/p...

  • iOS开发中的11种锁整理

    本文节选自成长手册 文章推荐和参考深入理解 iOS 开发中的锁pthread的各种同步机制 多线程编程被普遍认为复...

  • ThreadLocal源码分析

    ThreadLocal和线程同步机制相比:都是为了解决多线程中相同变量的访问冲突问题。在同步机制中,通过对象的锁机...

  • Android NDK - shell语法2

    方法参数传递机制详解 -- 函数编程 函数使用 阶乘函数 获取函数返回值 shell使用实例 - 执行编译ffmp...

  • iOS开发 非常全的三方库、插件、大牛博客等等(六)

    数据库 FMDB- sqlite的工具,多线程FMDatabaseQueue实例,FMDB数据库的使用演示和封装工...

网友评论

      本文标题:C++多线程编程和同步机制:详解和实例演示

      本文链接:https://www.haomeiwen.com/subject/yqhcsdtx.html