Shulou(Shulou.com)06/01 Report--

This article will explain in detail what is the queue for thread safety in C++. The editor thinks it is very practical, so I share it for you as a reference. I hope you can get something after reading this article.

Unbounded queue # include#include#include#include#include#includetemplateclass Queue / / Unbounded queue {public: Queue () = default; ~ Queue () = default; / / disable copying and moving, the compiler will automatically delete / * Queue (const Queue&) = delete; Queue (Queue&&) = delete; Queue& operator= (const Queue&) = delete; Queue& operator= (Queue&&) = delete * / void push (const T & val) {emplace (val);} void push (std::move & val) {emplace (std::move (val));} template void emplace (Args&&...args) {std::lock_guard lk {mtx_} Q_.push (std::forward (args)...); cv_.notify_one ();} T pop () / / blocking {std::unique_lock lk {mtx_}; cv_.wait (lk, [this] {return! q_.empty ();}) / / continue execution if the queue is not empty, otherwise block assert (! q_.empty ()); T ret {std::move_if_noexcept (q_.front ())}; q_.pop (); return ret } std::optional try_pop () / / non-blocking {std::unique_lock lk {mtx_}; if (q_.empty ()) return {}; std::optional ret {std::move_if_noexcept (q_.front ())}; q_.pop (); return ret } bool empty () const {std::lock_guard lk {mtx_}; return q_.empty ();} private: Container Qothers; mutable std::mutex mtx_; std::condition_variable cv_;}; # includeint main () {Queueq Std::thread T1 ([&] {for (int I = 0; I < 100; + + I) {q.push (I);}}) Std::thread T2 ([&] {for (int I = 0; I < 100; + I) {/ / std::cout

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.