Wie implementiert man Multithreading mithilfe der C++-Standardbibliothek?

Methoden zum Implementieren von Multithreading in der C++-Standardbibliothek: Header-Dateien einschließen: #include Thread-Objekte erstellen: std::thread t(function_or_lambda) Threads starten: t.start() warten, bis Threads abgeschlossen sind: t .join()

Verwenden Sie die C++-Standardbibliothek, um Multithreading zu implementieren.

Multithreading bezieht sich auf die gleichzeitige Ausführung mehrerer verschiedener Aufgaben in einem Programm. Dies ist ein sehr wichtiges Konzept zur Verbesserung der Programmparallelität und -reaktion Geschwindigkeit. Die C++-Standardbibliothek bietet mehrere Klassen und Funktionen, die Multithreading vereinfachen.

So implementieren Sie Multithreading mit der C++-Standardbibliothek:

1. Header-Dateien einschließen:

   #include 

   Nach dem Login kopieren

2. Thread-Objekte erstellen:
   Verwenden Sie die Klassestd::thread, um Erstellen Sie ein Thread-Objekt und geben Sie die auszuführende Funktion oder das aufrufbare Objekt an.std::thread类来创建线程对象，并指定要执行的函数或可调用对象。

   std::thread t(function_or_lambda);

   Nach dem Login kopieren

3. 启动线程：
   使用std::thread::start()方法来启动线程。此方法将开始一个新的线程，并执行指定的函数或可调用对象。

   t.start();

   Nach dem Login kopieren

4. 等待线程完成：
   使用std::thread::join()

   t.join();

   Nach dem Login kopieren

Starten Sie einen Thread:

Verwenden Sie die Methodestd::thread::start(), um einen Thread zu starten. Diese Methode startet einen neuen Thread und führt die angegebene Funktion oder das aufrufbare Objekt aus.

#include  #include
          
           using namespace std; vector
           
            numbers = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10}; int num_threads = 4; int sum(const vector
            
             & arr, int start, int end) { int sum = 0; for (int i = start; i < end; i++) { sum += arr[i]; } return sum; } int main() { // 创建线程数组 vector
             
              threads(num_threads); // 计算每个线程负责的范围 int chunk_size = numbers.size() / num_threads; vector
              
               partial_sums(num_threads); for (int i = 0; i < num_threads; i++) { int start = i * chunk_size; int end = min((i + 1) * chunk_size, numbers.size()); // 创建线程并计算部分和 threads[i] = thread(sum, ref(numbers), start, end); } // 等待所有线程完成 for (int i = 0; i < num_threads; i++) { threads[i].join(); } // 计算总体和 int total_sum = 0; for (int partial_sum : partial_sums) { total_sum += partial_sum; } cout << "Total sum: " << total_sum << endl; return 0; }