c++ 线程_业界新闻

发布时间:2024-07-29 02:41

阅读量:0

在 C++ 中，std::thread 构造函数可以用于将参数传递给线程。这里是一个基本的示例，展示了如何使用 std::thread 来传递参数：

#include <iostream> #include <thread>  // 定义一个被线程调用的函数 void threadFunc(int arg1, double arg2, std::string arg3) {     std::cout << "arg1: " << arg1 << ", arg2: " << arg2 << ", arg3: " << arg3 << std::endl; }  int main() {     // 创建一个线程，并传递参数     std::thread t(threadFunc, 1, 3.14, "Hello, World!");      // 等待线程结束     t.join();      return 0; }

在这个例子中，定义了一个函数 threadFunc，它接受三个参数。然后在 main 函数中创建了一个线程，并将这三个参数传递给了 threadFunc。

如果函数参数是引用类型，可以使用 std::ref 或 std::cref 来传递引用：

#include <iostream> #include <thread> #include <functional> // std::ref 和 std::cref 需要这个头文件  // 定义一个被线程调用的函数 void threadFunc(int &arg1, double &arg2, std::string &arg3) {     std::cout << "arg1: " << arg1 << ", arg2: " << arg2 << ", arg3: " << arg3 << std::endl; }  int main() {     int arg1 = 1;     double arg2 = 3.14;     std::string arg3 = "Hello, World!";      // 创建一个线程，并传递参数引用     std::thread t(threadFunc, std::ref(arg1), std::ref(arg2), std::ref(arg3));      // 等待线程结束     t.join();      return 0; }

在这个例子中，使用 std::ref 来传递变量的引用，这样就可以在 threadFunc 中修改这些变量的值。

std::ref 和 std::cref 是 C++11 引入的，用于在函数绑定或异步函数调用中引用成员函数或者非成员函数。这些函数主要在多线程中使用，目的是在函数调用中保持对象的引用，而不是复制对象。

`std::ref` 和 `std::cref` 的使用

std::ref:
std::ref 用于在函数绑定或异步函数调用中引用非 const 对象。例如：
```
std::thread t(func, std::ref(myObj)); 
```
std::cref:
std::cref 类似于 std::ref，但它用于引用 const 对象。例如：
```
std::thread t(func, std::cref(myObj)); 
```

这两个函数都定义在 <functional> 头文件中，因此在使用它们之前，必须包含这个头文件。

多线程示例

以下是一个示例，展示了如何使用 std::thread 和 std::promise 进行线程同步：

#include <iostream> #include <thread> #include <future> #include <string>  int main() {     std::promise<std::string> promise;     std::future<std::string> future = promise.get_future();      std::thread t([&promise] {         std::string s = "hello";         std::this_thread::sleep_for(std::chrono::seconds(1));         promise.set_value(s);     });      t.join();     std::string value = future.get();     std::cout << value << std::endl;      return 0; }

使用信号量的多线程示例

下面是一个使用信号量和互斥锁进行线程同步的示例：

#include <iostream> #include <thread> #include <vector> #include <mutex> #include <semaphore.h>  std::mutex mtx; sem_t sem; int counter = 0;  void increment_counter(int id) {     sem_wait(&sem);     std::lock_guard<std::mutex> lock(mtx);     std::this_thread::sleep_for(std::chrono::milliseconds(100));     counter++;     std::cout << "Thread " << id << " incremented counter to " << counter << std::endl;     sem_post(&sem); }  void read_counter(int id) {     sem_wait(&sem);     std::lock_guard<std::mutex> lock(mtx);     std::this_thread::sleep_for(std::chrono::milliseconds(100));     std::cout << "Thread " << id << " read counter value " << counter << std::endl;     sem_post(&sem); }  int main() {     sem_init(&sem, 0, 5);      std::vector<std::thread> threads;     for (int i = 0; i < 10; ++i) {         if (i % 2 == 0) {             threads.push_back(std::thread(increment_counter, i));         } else {             threads.push_back(std::thread(read_counter, i));         }     }      for (auto &thread : threads) {         thread.join();     }      sem_destroy(&sem);      return 0; }