En programmation simultanée, les objets fonction STL peuvent simplifier le traitement parallèle grâce aux applications suivantes : Traitement de tâches parallèles : encapsuler des objets fonction dans des tâches pouvant être exécutées en parallèle. Traitement de la file d'attente : stockez les objets de fonction et planifiez-les sur différents threads. Gestion des événements : enregistrez l'objet fonction en tant qu'écouteur d'événement et exécutez-le lorsque l'événement est déclenché.
Application des objets fonction STL dans la gestion de la programmation simultanée
Dans la programmation simultanée, les objets fonction fournissent des outils puissants pour traiter des tâches complexes et chronophages. La bibliothèque STL fournit une riche collection d'objets fonction qui simplifient le traitement parallèle et améliorent la lisibilité et la maintenabilité du code.
Objet fonction
Un objet fonction est une classe ou une structure qui implémente operator()
ou call
. Elles se comportent comme des fonctions normales mais peuvent être transmises, stockées et manipulées en tant qu'objets. operator()
或 call
的类或结构。它们的行为类似于普通函数,但可以作为对象进行传递、存储和操作。
并发编程中的应用
在并发编程中,函数对象可以用于:
std::thread
或 std::async
将函数对象封装成可并行执行的任务。std::queue
Traitement de tâches parallèles : En utilisant std::thread
ou std ::async
encapsule les objets fonction dans des tâches qui peuvent être exécutées en parallèle.
Utilisez std::queue
pour stocker les objets de fonction et les planifier en tant que tâches sur différents threads.
struct SumPartition { int operator()(int start, int end) { int sum = 0; for (int i = start; i < end; ++i) { sum += array[i]; } return sum; } int* array; };
#include <iostream> #include <thread> #include <vector> using namespace std; int main() { // 输入数组 vector<int> array = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10}; // 分区大小 int partitionSize = 2; // 创建线程池 vector<thread> threads; int numPartitions = array.size() / partitionSize; // 启动并行求和 for (int i = 0; i < numPartitions; ++i) { int start = i * partitionSize; int end = start + partitionSize; threads.emplace_back(thread(SumPartition(), start, end, array.data())); } // 等待线程完成 for (auto& thread : threads) { thread.join(); } // 计算最终结果 int totalSum = 0; for (int i = 0; i < numPartitions; ++i) { totalSum += SumPartition()(i * partitionSize, i * partitionSize + partitionSize, array.data()); } cout << "Total sum: " << totalSum << endl; return 0; }
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!