做微信小程序和网站那个简单,网站空间推荐,修改WordPress上传图片时间,长沙装修公司招聘信息异步并发——async future packaged_task promise
1.async、future
是C11引入的一个函数模版#xff0c;用于异步执行一个函数#xff0c;并返回一个future对象#xff0c;表示异步操作的结果。使用 async 可以方便地进行异步编程#xff0c;避免了手动创建线程和管理线程…异步并发——async future packaged_task promise
1.async、future
是C11引入的一个函数模版用于异步执行一个函数并返回一个future对象表示异步操作的结果。使用 async 可以方便地进行异步编程避免了手动创建线程和管理线程的麻烦。
代码参考
#includeiostream
#includefuture
#includethread
using namespace std;int func() {int i 0;for (int j 0; j 1000; j) {i;}return i;
}int main() {futureint future_result async(launch::async, func);cout func() endl;cout future_result.get() endl;return 0;
}
这个例子中使用了async函数异步执行了一个耗时的计算这个计算可以在另一个线程中执行不会阻塞主线程。同时我们也避免了手动创建线程和管理线程的麻烦。
2.packaged_task
在C中packaged_task是一个类模板用于将一个可调用对象如函数、函数对象或Lambda表达式封装成一个异步撮作并返回一个std::future对象表示异步操作的结果。packaged_task可以方便地将一个函数或可调用对象转换成一个异步操作供其他线程使用。
代码参考
#includeiostream
#includefuture
#includethread
using namespace std;int func() {int i 0;for (int j 0; j 1000; j) {i;}return i;
}int main() {packaged_taskint() task(func);futureintfuture_result task.get_future();thread t1(move(task));cout func() endl;t1.join();cout future_result.get() endl;return 0;
}
在这个例子中我们成功地将一个函数封装成了一个异步操作并在其他线程中执行。通过packaged_task和future对象我们可以方便地实现异步编程使得代码更加简洁和易于维护。
3.promise
在C中promise是一个类模版用于在一个线程中产生一个值并在另一个线程中获取这个值。promise通常与future和async一起使用用于实现异步编程。
#includeiostream
#includefuture
using namespace std;void fun(promiseint f) {f.set_value(1000); //传入数据
}int main() {promiseint f;auto future_result f.get_future();thread t1(fun, ref(f));t1.join();cout future_result.get() endl;return 0;}
实现一个数据的传入和使用。 原子操作 atomic
std::atomic 是 C11 标准库中的一个模板类用于实现多线程环境下的原子操作。它提供了一种线程安全的方式来访问和修改共享变量可以避免多线程环境中的数据竞争问题。 std::atomic 的使用方式类似于普通的 C 变量但是它的操作是原子性的。也就是说在多线程环境下多个线程同时对同一个 std::atomic 变量进行操作时不会出现数据竞争问题。
以下是一些常用的 std::atomic 操作
load()将 std::atomic 变量的值加载到当前线程的本地缓存中并返回这个值。store(val)将 val 的值存储到 std::atomic 变量中并保证这个操作是原子性的。exchange(val)将 val 的值存储到 std::atomic 变量中并返回原先的值。compare_exchange_weak(expected, val) 和 compare_exchange_strong(expected, val)比较 std::atomic 变量的值和 expected 的值是否相同如果相同则将 val 的值存储到 std::atomic 变量中并返回 true否则将 std::atomic 变量的值存储到 expected 中并返回 false。
代码参考
#includeiostream
#includethread
#includeatomic
using namespace std;//原子量
atomicint sharted_data 0;
void func() {for (int i 0; i 10000; i) {sharted_data; //对原子量数据操作是线程安全的 }
}
int main() {thread t1(func);thread t2(func);t1.join();t2.join();cout sharted_data endl;return 0;
}
