Bagaimana untuk menggunakan coroutine untuk melaksanakan pengaturcaraan serentak dalam C++?

Cara menggunakan coroutine untuk melaksanakan pengaturcaraan serentak dalam C++

Coroutines ialah primitif konkurensi ringan yang membolehkan pengaturcara melaksanakan tugas selari tanpa mencipta urutan yang berasingan. Ini berguna untuk aplikasi intensif I/O kerana coroutine menggunakan lebih sedikit overhed daripada benang apabila menukar tugas.

Coroutine dalam C++

Coroutines telah diperkenalkan dalam C++ 20 sebagai rangka kerja std::coroutine. Coroutine ialah fungsi penjana yang boleh menangguhkan pelaksanaan dan mengembalikan nilai melalui ungkapan co_yield. Tidak seperti penjana biasa, coroutine boleh menggantung dan menyambung semula pelaksanaan beberapa kali.

// 一个协程示例
std::coroutine<int> my_coroutine() {
  int value = 0;
  while (true) {
    value++;
    co_yield value;  // 挂起执行并返回 value
  }
}

Contoh praktikal coroutines

Coroutines sangat berguna dalam senario berikut:

• Operasi I/O yang tidak menyekat: Coroutines yang tidak menyekat boleh digunakan untuk melaksanakan rangkaian/O permintaan atau fail Baca.
• Paip dan Penapis: Coroutine boleh digunakan untuk mencipta saluran paip dan penapis untuk memproses dan mengubah aliran data.
• Selaraskan tugas serentak: Coroutine boleh digunakan untuk menyelaraskan berbilang tugas serentak, seperti pemprosesan data selari atau pengkomputeran teragih.

Contoh: Menggunakan coroutine untuk I/O tidak menyekat

Contoh berikut menunjukkan cara menggunakan coroutine untuk permintaan rangkaian tidak menyekat:

#include <iostream>
#include <future>

// 一个协程来发送 HTTP 请求
std::coroutine<std::string> get_url(const std::string& url) {
  // 创建一个 HTTP 客户端
  auto client = std::make_unique<cpprestsdk::http_client>(url);
  
  // 向服务器发送 GET 请求
  auto response = co_await client->request(cpprestsdk::methods::GET);
  
  // 返回响应体
  co_return response.extract_string().get();
}

int main() {
  // 并发发送两个 HTTP 请求
  auto f1 = std::async(std::launch::async, get_url("https://example.com/1"));
  auto f2 = std::async(std::launch::async, get_url("https://example.com/2"));
  
  // 获取请求结果
  std::cout << f1.get() << std::endl;
  std::cout << f2.get() << std::endl;
}

Atas ialah kandungan terperinci Bagaimana untuk menggunakan coroutine untuk melaksanakan pengaturcaraan serentak dalam C++?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!