[C++] ใช้ CPU ให้เต็มที่ด้วย Boost Thread Pool

n = [1, 2, 3]

void process(int a, int b)
{
        cout << a << "+" << b << " = " << a + b << "\n";
}

#include <iostream>
#include <vector>

using namespace std;

void process(int a, int b)
{
        cout << a << "+" << b << " = " << a + b << "\n";
}

int main()
{
        vector<int> vs = {1, 2, 3, 4, 5};

        for (const auto &a : vs)
        {
                for (const auto &b : vs)
                {
                        process(a, b);
                }
        }
        return EXIT_SUCCESS;
}

#include <boost/asio.hpp>
#include <boost/thread/mutex.hpp>

#include <iostream>
#include <vector>
#include <thread>
#include <functional>

using namespace std;

void process(boost::mutex &io_mutex, int a, int b)
{
        boost::mutex::scoped_lock scoped_lock(io_mutex);
        cout << a << "+" << b << " = " << a + b << "\n";
}

int main()
{
        // สร้าง thread_pool object เก็บในตัวแปร pool
        // โดยกำหนดให้จำนวน thread เท่ากับ core ของ CPU ของเครื่องที่รัน
        // เช็คได้จาก function hardward_concurrency
        boost::asio::thread_pool pool(thread::hardware_concurrency());

        // สร้าง mutex เพื่อช่วยให้ตอน cout ไม่เกิด race condition ที่ทำให้ผลลัพธ์เพี้ยนๆ
        boost::mutex io_mutex;

        vector<int> vs = {1, 2, 3, 4, 5};

        for (const auto &a : vs)
        {
                for (const auto &b : vs)
                {
                        // ส่งฟังก์ชันไปรันใน thread pool ด้วยฟังก์ชัน post
                        // ซึ่งเราต้องใช้ std::bind ฟังก์ชันกับ parameter ของฟังก์ชันก่อนส่งให้ post ด้วย
                        // และส่ง reference io_mutex เข้าไปด้วยเพื่อใช้ scoped_lock กันแย่งกัน print output
                        boost::asio::post(pool, std::bind(process, std::ref(io_mutex), a, b));
                }
        }

        // เรียก pool.join() เพื่อรอให้ทุก process ทำงานจบก่อนแล้วค่อยจบโปรแกรม
        pool.join();

        return EXIT_SUCCESS;
}

#include <boost/asio.hpp>
#include <boost/thread/mutex.hpp>

#include <iostream>
#include <vector>
#include <thread>
#include <functional>

using namespace std;

void process(boost::mutex &io_mutex, int a, int b)
{
        boost::mutex::scoped_lock scoped_lock(io_mutex);
        cout << a << "+" << b << " = " << a + b << "\n";
}

int main()
{
        // สร้าง thread_pool object เก็บในตัวแปร pool
        // โดยกำหนดให้จำนวน thread เท่ากับ core ของ CPU ของเครื่องที่รัน
        // เช็คได้จาก function hardward_concurrency
        boost::asio::thread_pool pool(thread::hardware_concurrency());

        // สร้าง mutex เพื่อช่วยให้ตอน cout ไม่เกิด race condition ที่ทำให้ผลลัพธ์เพี้ยนๆ
        boost::mutex io_mutex;

        vector<int> vs = {1, 2, 3, 4, 5};

        for (const auto &a : vs)
        {
                for (const auto &b : vs)
                {

                        // ส่งฟังก์ชันไปรันใน thread pool ด้วยฟังก์ชัน post
                        // โดยส่ง lambda express ที่เรียก process ข้างใน
                        boost::asio::post(
                            pool,
                            // lambda express syntax
                            // แบบนี้คือ [&] หมายถึงทุกตัวแปรที่ capture จาก scope ด้านนอกใช้เป็น reference
                            // ทั้ง io_mutex, a, b โดยเราไม่ต้องลิสต์เองทีละอัน
                            [&]()
                            {
                                    process(io_mutex, a, b);
                            });
                        // boost::asio::post(pool, std::bind(process, std::ref(io_mutex), a, b));
                }
        }

        // เรียก pool.join() เพื่อรอให้ทุก process ทำงานจบก่อนแล้วค่อยจบโปรแกรม
        pool.join();

        return EXIT_SUCCESS;
}