浅谈c++11线程的互斥量

2024-04-02 19:04:59 337人浏览安东尼

摘要

目录为什么需要互斥量独占互斥量std::mutex原子操作为什么需要互斥量在多任务操作系统中，同时运行的多个任务可能都需要使用同一种资源。这个过程有点类似于，公司部门里，我在使用着

为什么需要互斥量

在多任务操作系统中，同时运行的多个任务可能都需要使用同一种资源。这个过程有点类似于，公司部门里，我在使用着打印机打印东西的同时（还没有打印完），别人刚好也在此刻使用打印机打印东西，如果不做任何处理的话，打印出来的东西肯定是错乱的。


#define _CRT_SECURE_NO_WARNINGS

#include <iOStream>
#include <string>
#include <chrono>
#include <thread>

// 打印机
void printer(const char *str)
{
    while(*str != '\0')
    {
        std::cout << *str;
        str++;
        std::this_thread::sleep_for(std::chrono::milliseconds(1000));
    }
    std::cout << std::endl;
}

// 线程一
void func1()
{
    const char *str = "hello";
    printer(str);
}

// 线程二
void func2()
{
    const char *str = "world";
    printer(str);
}


void mytest()
{
    std::thread t1(func1);
    std::thread t2(func2);

    t1.join();
    t2.join();

    return;
}

int main()
{
    mytest();

    system("pause");
    return 0;
}

独占互斥量std::mutex

互斥量的基本接口很相似，一般用法是通过lock()方法来阻塞线程，直到获得互斥量的所有权为止。在线程获得互斥量并完成任务之后，就必须使用unlock()来解除对互斥量的占用，lock()和unlock()必须成对出现。try_lock()尝试锁定互斥量，如果成功则返回true, 如果失败则返回false，它是非阻塞的。


#define _CRT_SECURE_NO_WARNINGS

#include <iostream>
#include <string>
#include <chrono>
#include <thread>
#include <mutex>

std::mutex g_lock; //全局互斥锁对象，#include <mutex>

// 打印机
void printer(const char *str)
{
    g_lock.lock(); //上锁
    while(*str != '\0')
    {
        std::cout << *str;
        str++;
        std::this_thread::sleep_for(std::chrono::milliseconds(1000));
    }
    std::cout << std::endl;
    g_lock.unlock(); // 解锁
}

// 线程一
void func1()
{
    const char *str = "hello";
    printer(str);
}

// 线程二
void func2()
{
    const char *str = "world";
    printer(str);
}


void mytest()
{
    std::thread t1(func1);
    std::thread t2(func2);

    t1.join();
    t2.join();

    return;
}

int main()
{
    mytest();

    system("pause");
    return 0;
}

使用std::lock_guard可以简化lock/unlock的写法，同时也更安全，因为lock_guard在构造时会自动锁定互斥量，而在退出作用域后进行析构时就会自动解锁，从而避免忘了unlock操作。


#define _CRT_SECURE_NO_WARNINGS

#include <iostream>
#include <string>
#include <chrono>
#include <thread>
#include <mutex>

std::mutex g_lock; //全局互斥锁对象，#include <mutex>

// 打印机
void printer(const char *str)
{
    std::lock_guard<std::mutex> locker(g_lock); // lock_guard 上锁
    while(*str != '\0')
    {
        std::cout << *str;
        str++;
        std::this_thread::sleep_for(std::chrono::milliseconds(1000));
    }
    std::cout << std::endl;
    // 即将推出作用域 lock_guard 会自动解锁
}

// 线程一
void func1()
{
    const char *str = "hello";
    printer(str);
}

// 线程二
void func2()
{
    const char *str = "world";
    printer(str);
}


void mytest()
{
    std::thread t1(func1);
    std::thread t2(func2);

    t1.join();
    t2.join();

    return;
}

int main()
{
    mytest();

    system("pause");
    return 0;
}

原子操作

所谓的原子操作，取的就是“原子是最小的、不可分割的最小个体”的意义，它表示在多个线程访问同一个全局资源的时候，能够确保所有其他的线程都不在同一时间内访问相同的资源。也就是他确保了在同一时刻只有唯一的线程对这个资源进行访问。这有点类似互斥对象对共享资源的访问的保护，但是原子操作更加接近底层，因而效率更高。


#define _CRT_SECURE_NO_WARNINGS

#include <iostream>
#include <string>
#include <chrono>
#include <thread>

//全局的结果数据
long total = 0;

//点击函数
void func()
{
    for(int i = 0;  i < 1000000; ++i)
    {
        // 对全局数据进行无锁访问
        total += 1;
    }
}


void mytest()
{
    clock_t start = clock();    // 计时开始

    //线程
    std::thread t1(func);
    std::thread t2(func);

    t1.join();
    t2.join();

    clock_t end = clock();    // 计时结束

    std::cout << "total = " << total << std::endl;
    std::cout << "time = " << end-start << " ms" << std::endl;


    return;
}

int main()
{
    mytest();

    system("pause");
    return 0;
}

由于线程间对数据的竞争而导致每次运行的结果都不一样。因此，为了防止数据竞争问题，我们需要对total进行原子操作。

通过互斥锁进行原子操作：


#define _CRT_SECURE_NO_WARNINGS

#include <iostream>
#include <string>
#include <chrono>
#include <thread>
#include <mutex>

std::mutex g_lock;

//全局的结果数据
long total = 0;

//点击函数
void func()
{
    for(int i = 0;  i < 1000000; ++i)
    {
        g_lock.lock(); // 加锁
        total += 1;
        g_lock.unlock(); // 加锁
    }
}


void mytest()
{
    clock_t start = clock();    // 计时开始

    //线程
    std::thread t1(func);
    std::thread t2(func);

    t1.join();
    t2.join();

    clock_t end = clock();    // 计时结束

    std::cout << "total = " << total << std::endl;
    std::cout << "time = " << end-start << " ms" << std::endl;


    return;
}

int main()
{
    mytest();

    system("pause");
    return 0;
}

每次运行的结果都一样，只是耗时长点。

在新标准c++11，引入了原子操作的概念。

如果我们在多个线程中对这些类型的共享资源进行操作，编译器将保证这些操作都是原子性的，也就是说，确保任意时刻只有一个线程对这个资源进行访问，编译器将保证多个线程访问这个共享资源的正确性。从而避免了锁的使用，提高了效率。


#define _CRT_SECURE_NO_WARNINGS

#include <iostream>
#include <string>
#include <chrono>
#include <thread>
#include <atomic>

//原子数据类型
std::atomic<long> total(0); //需要头文件 #include <atomic>

//点击函数
void func()
{
    for(int i = 0;  i < 1000000; ++i)
    {
        // 
        total += 1;
    }
}


void mytest()
{
    clock_t start = clock();    // 计时开始

    //线程
    std::thread t1(func);
    std::thread t2(func);

    t1.join();
    t2.join();

    clock_t end = clock();    // 计时结束

    std::cout << "total = " << total << std::endl;
    std::cout << "time = " << end-start << " ms" << std::endl;


    return;
}

int main()
{
    mytest();

    system("pause");
    return 0;
}

原子操作的实现跟普通数据类型类似，但是它能够在保证结果正确的前提下，提供比mutex等锁机制更好的性能。

以上就是浅谈c++11线程的互斥量的详细内容，更多关于c++11线程的互斥量的资料请关注编程网其它相关文章！

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: 浅谈c++11线程的互斥量

本文链接: https://www.lsjlt.com/news/127849.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

猜你喜欢

浅谈c++11线程的互斥量

目录为什么需要互斥量独占互斥量std::mutex原子操作为什么需要互斥量在多任务操作系统中，同时运行的多个任务可能都需要使用同一种资源。这个过程有点类似于，公司部门里，我在使用着...

99+

2022-11-12
c++11线程为什么需要互斥量

这篇文章给大家分享的是有关c++11线程为什么需要互斥量的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。为什么需要互斥量在多任务操作系统中，同时运行的多个任务可能都需要使用同一种资源。这个过程有点类似于，公司部门里...

99+

2023-06-15
C++11线程、互斥量及条件变量怎么创建

这篇“C++11线程、互斥量及条件变量怎么创建”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“C++11线程、互斥量及条件变量...

99+

2023-07-05
C++ 多线程之互斥量(mutex)详解

目录std::mutexstd::recursive_mutexstd::time_mutexstd::recursive_timed_mutexstd::shared_mutexs...

99+

2022-11-13
C++详解多线程中的线程同步与互斥量

目录线程同步互斥量线程同步 #include <stdio.h> #include <pthread.h> #include <unistd.h>...

99+

2022-11-13
浅谈C#多线程下的调优

目录一、原子操作1.基于Lock实现2.基于CAS实现3.自旋锁SpinLock4.读写锁ReaderWriterLockSlim二、线程安全1.线程安全集合2.线程安全字典三、线程...

99+

2022-11-13
C++多线程中的线程同步与互斥量实例分析

本篇内容介绍了“C++多线程中的线程同步与互斥量实例分析”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！线程同步#include &...

99+

2023-06-30
C#多线程中的互斥锁Mutex

一、简介 Mutex的突出特点是可以跨应用程序域边界对资源进行独占访问，即可以用于同步不同进程中的线程，这种功能当然这是以牺牲更多的系统资源为代价的。主要常用的两个方法: publ...

99+

2022-11-13
C++多线程互斥锁和条件变量的详解

目录互斥锁：std::mutex::try_lock 条件变量：condition_variable总结我们了解互斥...

99+

2022-11-13
C#多线程中的互斥锁Mutex怎么用

本篇内容主要讲解“C#多线程中的互斥锁Mutex怎么用”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“C#多线程中的互斥锁Mutex怎么用”吧!一、简介Mutex的突出特点是可以跨应用程序域边界对...

99+

2023-06-30
C++线程间的互斥和通信场景分析

目录互斥锁（mutex）模拟车站卖票不加锁的结果加锁后的结果简单总结条件变量（conditon_variable）生产者消费者线程模型产生问题解决问题原子类型（atomic）简单使用...

99+

2022-11-12
详解C++11中的线程锁和条件变量

目录线程锁条件变量小结线程 std::thread类，位于<thread>头文件，实现了线程操作。std::thread可以和普通函数和 lambda 表达式搭配使用。...

99+

2022-11-12
C++11中线程、锁和条件变量的介绍

这篇文章主要介绍“C++11中线程、锁和条件变量的介绍”，在日常操作中，相信很多人在C++11中线程、锁和条件变量的介绍问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”C++11中线程、锁和条件变量的介绍”的疑...

99+

2023-06-17
C++11中线程锁和条件变量的示例分析

这篇文章主要介绍了C++11中线程锁和条件变量的示例分析，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。线程std::thread类，位于<thread>头文件，...

99+

2023-06-15
C/C++中多进程之间的线程如何利用XSI IPC共享内存分配互斥量进行同步

这篇文章主要介绍了C/C++中多进程之间的线程如何利用XSI IPC共享内存分配互斥量进行同步，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。#include <stdi...

99+

2023-06-03
怎么理解C++11 中的线程及锁和条件变量

今天就跟大家聊聊有关怎么理解C++11 中的线程及锁和条件变量，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。线程类std::thread代表一个可执行线程，使用时必须包含头文件<...

99+

2023-06-17
详解java中的互斥锁信号量和多线程等待机制

互斥锁和信号量都是操作系统中为并发编程设计基本概念，互斥锁和信号量的概念上的不同在于，对于同一个资源，互斥锁只有0和1 的概念，而信号量不止于此。也就是说，信号量可以使资源同时被多个线程访问，而互斥锁同时只能被一个线程访问互斥锁在java中...

99+

2023-05-31

java 互斥锁信号量