cond5future关联packaged_task实现线程池
相关推荐
2024-10-10
条件变量实现安全队列和信号量
条件变量实现安全队列一些源码的解释 12#include <condition_variable>std::codition_variable cv; // wake up one waiter 1void notify_one() noexcept // wake up all waiters 1void notify_all() noexcept Nothing to do to comply with LWG-2135 because std::mutex lock/unlock are nothrow 1void wait(unique_lock<mutex>& _Lck) // wait for signal and test predicate 123456template <class _Predicate>void wait(unique_lock<mutex>& _Lck, _Predicate _Pred)...
2024-10-10
互斥和锁
互斥c++通过std::mutex实现锁机制，确保多线程下只有一个进入临界区 1234#include <mutex>std::mutex mtx;mtx.lock();mtx.unlock(); 层级锁自定义锁添加权重来保证每次加锁顺序和解锁顺序，数值越大权重越高 12345678910111213141516171819class hmutex {public: hmutex(unsigned value):cur(val),pre(0)void lock(){ if(cur <= val) std::logic_error("faild"); mtx.lock(); pre=cur,cur=val;}void unlock(){ if(cur != val) std::logic_error("faild"); mtx.unlock(); cur=pre;}private:std::mutex mtx;unsigned val;unsigned...
2024-10-10
CAS实现无锁队列
悲观锁：阻塞线程，等待锁释放，发生上下文切换 乐观锁：修改时检查，失败则不断重试 汇编原子操作： 12345678910int inc(int* value, int add) { int old; __asm__ volatile ( "lock; xaddl %2, %1;" // 指令1：lock; 指令2: xaddl, 操作数占位符：%1, %2 : "=a" (old) // 输出：结果放入通用寄存器eax : "m" (*value), "a" (add) // 输入：操作数1（内存），操作数2（寄存器eax） : "cc", "memory" // 编译方式，内存 ); return...
2024-10-10
并发技术future类
Future使用搭配async启动一个异步任务，返回一个future对象 1234std::future<int> res = std::async(std::launch::async, []{ std::this_thread::sleep_for(std::chrono::seconds(5)); return 1;}); int i =...
2024-10-11
cond6并行计算及两种并发模型
并行计算利用cpu多核计算子集，然后合并返回结果；例如在快排中，本身计算privot左边，交给子线程计算privot右边 倘若我们要实现一套通用的规则而不依赖于存储容器，那就可以使用函数式编程 程序由一系列函数组成，每一步计算就是函数求值，并且不改变状态和数据（那样拷贝数据返回新值挺费内存吧） 12345678910111213141516171819202122232425template<class T>std::list<T> parallel_quick_sort(std::list<T> input) { if(input.empty()) return input; std::list<T> result; // 转移，前插 result.splice(result.begin(), input, input.begin()); T const& pivot = *result.begin(); 基于privot拆分链表 auto divide_point =...
2024-10-10
C++线程与源码学习
C++线程std::thread创建thread封装线程操作，通过std::tread(func)传入函数指针，创建一个对象并初始化即开启一个线程执行 注意： 这里可以传入成员函数，但必须加& 这里也可以传入仿函数，但是编译器会认为t1是一个函数指针的类型，可以使用{}统一初始化来指出这是一个thread对象 12345678910111213class func {public: void operator()() { std::cout << "这是一个仿函数" << std::endl; }};int main(){ std::thread t1(func()); std::thread t2{func()}; t2.join(); std::cout << typeid(t1).name() << std::endl; std::cout << typeid(t2).name()...