首页 后端开发 C++ C++中的多线程优化技巧

C++中的多线程优化技巧

Aug 22, 2023 pm 12:53 PM
多线程 c++ 优化技巧

C++中的多线程优化技巧

随着计算机技术的发展和硬件性能的提升,多线程技术已经成为了现代编程的必备技能。C++是一门经典的编程语言,也提供了许多强大的多线程技术。本文将介绍C++中的一些多线程优化技巧,以帮助读者更好地应用多线程技术。

一、使用 std::thread

C++11引入了 std::thread,将多线程技术直接集成到了标准库中。使用 std::thread 创建一个新的线程非常简单,只需要传递一个函数指针即可。例如:

#include <thread>
#include <iostream>

void hello()
{
    std::cout << "Hello World!";
}

int main()
{
    std::thread t(hello);
    t.join();
    return 0;
}
登录后复制

上面的代码创建了一个新的线程t,执行hello函数,并等待线程t完成。注意,线程的创建和销毁需要一定的开销,因此需要合理地使用 std::thread。

二、使用 std::async

std::async是另一个方便的多线程技术,它可以异步地执行一个函数,并返回一个 std::future 对象。使用 std::async 可以更方便地管理异步任务的执行和结果获取。例如:

#include <future>
#include <iostream>

int add(int a, int b)
{
    return a + b;
}

int main()
{
    auto async_result = std::async(add, 1, 2);
    std::cout << async_result.get();
    return 0;
}
登录后复制

上面的代码调用add函数异步地计算1+2,并使用 std::future 对象管理计算结果的获取。需要注意的是,std::async 默认使用 std::launch::async 策略,会在新的线程中执行函数。如果希望使用 std::launch::deferred 策略,则需要手动指定。但是,使用 std::launch::deferred 策略会导致函数在调用 std::future::get() 时才执行,因此需要根据具体情况进行选择。

三、使用 std::condition_variable

在多线程编程中,线程之间需要进行通信和同步,而 std::condition_variable 可以很好地实现这个目的。使用 std::condition_variable 可以让一个线程等待另一个线程的某个条件成立,从而实现线程之间的同步。例如:

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

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

void producer()
{
    std::unique_lock<std::mutex> lock(mutex);
    // wait for the condition to become true
    cv.wait(lock, [] { return ready; });
    std::cout << "Producer done." << std::endl;
}

void consumer()
{
    std::this_thread::sleep_for(std::chrono::seconds(1));
    ready = true;
    std::cout << "Consumer done." << std::endl;
    cv.notify_one();
}

int main()
{
    std::thread t1(producer);
    std::thread t2(consumer);
    t1.join();
    t2.join();
    return 0;
}
登录后复制

上面的代码创建了两个线程t1和t2,其中t1在等待一个条件变量ready变为true之前一直处于等待状态,而t2则在等待1秒后设置条件变量为true,并通知t1。需要注意的是,使用 std::condition_variable 必须配合std::mutex一起使用,以防止多个线程同时访问条件变量的问题。

四、使用线程池

在大量需要创建并运行的短期任务的情况下,经常会使用线程池以提高程序的性能。线程池维护一定数量的线程并管理任务的分配和执行。使用线程池可以避免频繁创建和销毁线程的额外开销,同时可以充分利用多核CPU的优势。例如:

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <vector>
#include <queue>
#include <functional>

class ThreadPool
{
public:
    ThreadPool(std::size_t numThreads = std::thread::hardware_concurrency())
    {
        for (std::size_t i = 0; i < numThreads; ++i)
        {
            pool.emplace_back([this] {
                while (!stop)
                {
                    std::function<void()> task;
                    {
                        std::unique_lock<std::mutex> lock{ mutex };
                        condition.wait(lock, [this] { return stop || !tasks.empty(); });
                        if (stop && tasks.empty()) return;
                        task = std::move(tasks.front());
                        tasks.pop();
                    }
                    task();
                }
            });
        }
    }

    ~ThreadPool()
    {
        {
            std::unique_lock<std::mutex> lock{ mutex };
            stop = true;
        }
        condition.notify_all();
        for (auto& worker : pool)
        {
            worker.join();
        }
    }

    template <typename F, typename... Args>
    auto enqueue(F&& f, Args&&... args)
        -> std::future<typename std::result_of<F(Args...)>::type>
    {
        using return_type = typename std::result_of<F(Args...)>::type;
        auto task = std::make_shared<std::packaged_task<return_type()>>(
            std::bind(std::forward<F>(f), std::forward<Args>(args)...));
        std::future<return_type> future = task->get_future();
        {
            std::unique_lock<std::mutex> lock{ mutex };
            if (stop) throw std::runtime_error("enqueue on stopped ThreadPool");
            tasks.emplace([task](){ (*task)(); });
        }
        condition.notify_one();
        return future;
    }

private:
    std::vector<std::thread> pool;
    std::queue<std::function<void()>> tasks;
    std::mutex mutex;
    std::condition_variable condition;
    bool stop = false;
};

void hello()
{
    std::cout << "Hello World!" << std::endl;
}

int add(int a, int b)
{
    return a + b;
}

int main()
{
    {
        ThreadPool pool;
        auto f1 = pool.enqueue(hello);
        auto f2 = pool.enqueue(add, 1, 2);
        std::cout << f2.get() << std::endl;
    }
    return 0;
}
登录后复制

上面的代码定义了一个ThreadPool类,其中包含多个线程和一个任务队列。线程池不断从任务队列中取出任务并执行,直到队列为空或者线程池停止。使用 ThreadPool::enqueue 方法将任务加入任务队列,并返回一个 std::future 对象来管理任务执行的结果。

总的来说,C++提供了多种多线程技术来帮助开发者发挥多核CPU的性能,并能够更灵活地管理线程和任务。开发者应该合理使用这些技术来优化程序性能。

以上是C++中的多线程优化技巧的详细内容。更多信息请关注PHP中文网其他相关文章!

本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
1 个月前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳图形设置
1 个月前 By 尊渡假赌尊渡假赌尊渡假赌
威尔R.E.P.O.有交叉游戏吗?
1 个月前 By 尊渡假赌尊渡假赌尊渡假赌

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

char在C语言字符串中的作用是什么 char在C语言字符串中的作用是什么 Apr 03, 2025 pm 03:15 PM

在 C 语言中,char 类型在字符串中用于:1. 存储单个字符;2. 使用数组表示字符串并以 null 终止符结束;3. 通过字符串操作函数进行操作;4. 从键盘读取或输出字符串。

在Docker环境中使用PECL安装扩展时为什么会报错?如何解决? 在Docker环境中使用PECL安装扩展时为什么会报错?如何解决? Apr 01, 2025 pm 03:06 PM

在Docker环境中使用PECL安装扩展时报错的原因及解决方法在使用Docker环境时,我们常常会遇到一些令人头疼的问�...

c上标3下标5怎么算 c上标3下标5算法教程 c上标3下标5怎么算 c上标3下标5算法教程 Apr 03, 2025 pm 10:33 PM

C35 的计算本质上是组合数学,代表从 5 个元素中选择 3 个的组合数,其计算公式为 C53 = 5! / (3! * 2!),可通过循环避免直接计算阶乘以提高效率和避免溢出。另外,理解组合的本质和掌握高效的计算方法对于解决概率统计、密码学、算法设计等领域的许多问题至关重要。

c语言多线程的四种实现方式 c语言多线程的四种实现方式 Apr 03, 2025 pm 03:00 PM

语言多线程可以大大提升程序效率,C 语言中多线程的实现方式主要有四种:创建独立进程:创建多个独立运行的进程,每个进程拥有自己的内存空间。伪多线程:在一个进程中创建多个执行流,这些执行流共享同一内存空间,并交替执行。多线程库:使用pthreads等多线程库创建和管理线程,提供了丰富的线程操作函数。协程:一种轻量级的多线程实现,将任务划分成小的子任务,轮流执行。

distinct函数用法 distance函数c  用法教程 distinct函数用法 distance函数c 用法教程 Apr 03, 2025 pm 10:27 PM

std::unique 去除容器中的相邻重复元素,并将它们移到末尾,返回指向第一个重复元素的迭代器。std::distance 计算两个迭代器之间的距离,即它们指向的元素个数。这两个函数对于优化代码和提升效率很有用,但也需要注意一些陷阱,例如:std::unique 只处理相邻的重复元素。std::distance 在处理非随机访问迭代器时效率较低。通过掌握这些特性和最佳实践,你可以充分发挥这两个函数的威力。

蛇形命名法在C语言中如何应用? 蛇形命名法在C语言中如何应用? Apr 03, 2025 pm 01:03 PM

C语言中蛇形命名法是一种编码风格约定,使用下划线连接多个单词构成变量名或函数名,以增强可读性。尽管它不会影响编译和运行,但冗长的命名、IDE支持问题和历史包袱需要考虑。

C  中releasesemaphore的用法 C 中releasesemaphore的用法 Apr 04, 2025 am 07:54 AM

C 中 release_semaphore 函数用于释放已获得的信号量,以便其他线程或进程访问共享资源。它将信号量计数增加 1,允许阻塞的线程继续执行。

C   程序员&#s未定义行为指南 C 程序员&#s未定义行为指南 Apr 03, 2025 pm 07:57 PM

探索C语言编程的未定义行为:一本详尽指南本文介绍一本关于C语言编程中未定义行为的电子书,共12章,涵盖了C语言编程中一些最棘手和鲜为人知的方面。本书并非C语言入门教材,而是面向熟悉C语言编程的读者,深入探讨未定义行为的各种情况及其潜在后果。作者DmitrySviridkin,编辑AndreyKarpov。历经六个月的精心准备,这本电子书终于与读者见面。未来还将推出印刷版。本书最初计划包含11章,但在创作过程中,内容不断丰富,最终扩展到12章——这本身就是一个经典的数组越界案例,可谓是每个C程序员

See all articles