race-condition 相关问题

我有以下代码： #包括 #包括 #包括 #包括 #包括 #包括 #包括我有以下代码： #include <string> #include <thread> #include <memory> #include <condition_variable> #include <mutex> #include <deque> #include <iostream> #include <vector> #include "third_party/concurrentqueue.h" struct Dummy { std::string name_; }; class Consumer { public: Consumer() { is_running_ = true; data_thread_ = std::unique_ptr<std::thread>( new std::thread(&Consumer::listening, this)); } void push(std::shared_ptr<Dummy> frame) { nice_queue.enqueue(frame); } virtual void listening() { while (is_running_) { std::shared_ptr<Dummy> frame; if (nice_queue.try_dequeue(frame)) { // Is there a possible race condition, // as there is no memory fence? std::cout << frame->name_ << std::endl; // <<<<<< } } } std::unique_ptr<std::thread> data_thread_; moodycamel::ConcurrentQueue<std::shared_ptr<Dummy>> nice_queue; std::atomic<bool> is_running_; }; class Producer { public: Producer(std::shared_ptr<Consumer> consumer) :consumer_(consumer){} void send(std::shared_ptr<Dummy> frame) { consumer_->push(frame); } protected: std::shared_ptr<Consumer> consumer_; }; int main() { std::shared_ptr<Consumer> consumer = std::make_shared<Consumer>(); Producer prod(consumer); for(int i =0; i<100; i++){ auto item = std::make_shared<Dummy>(); item->name_ = std::to_string(i); prod.send(item); } } 如代码所示，Producer将一个项目发送到Consumer以在另一个线程中处理，因此两件事严格地相继发生，但由于没有内存栅栏，是否有可能当 Consumer 处理该项目，它看不到该项目的最终版本，因此具有未定义的行为？同步发生在 moodycamel::ConcurrentQueue 的幕后。正如名称（和文档）所示，它是一个线程安全队列。因此可以同时从不同线程写入和读取。喜怒无常的骆驼文档您发送shared_ptr的事实不会对这里产生任何影响。

c++ race-condition

回答 1 投票 0

c++ 是否存在可能的竞争条件，为什么？

我有以下代码， #包括 #包括 #包括 #包括 #包括 #包括 #包括我有以下代码， #include <string> #include <thread> #include <memory> #include <condition_variable> #include <mutex> #include <deque> #include <iostream> #include <vector> #include "third_party/concurrentqueue.h" struct Dummy { std::string name_; }; class Consumer { public: Consumer() { is_running_ = true; data_thread_ = std::unique_ptr<std::thread>(new std::thread(&Consumer::listening, this)); } void push(std::shared_ptr<Dummy> frame) { nice_queue.enqueue(frame); } virtual void listening() { while (is_running_) { std::shared_ptr<Dummy> frame; if (nice_queue.try_dequeue(frame)) { std::cout << frame->name_ << std::endl; //<--- is here a possible race condition as there is no memory fence } } } std::unique_ptr<std::thread> data_thread_; moodycamel::ConcurrentQueue<std::shared_ptr<Dummy>> nice_queue; std::atomic<bool> is_running_; }; class Producer { public: Producer(std::shared_ptr<Consumer> consumer) :consumer_(consumer){} void send(std::shared_ptr<Dummy> frame) { consumer_->push(frame); } protected: std::shared_ptr<Consumer> consumer_; }; int main() { std::shared_ptr<Consumer> consumer = std::make_shared<Consumer>(); Producer prod(consumer); for(int i =0; i<100; i++){ auto item = std::make_shared<Dummy>(); item->name_ = std::to_string(i); prod.send(item); } } 我的问题是，如代码所示，Producer将一个项目发送到Consumer以在另一个线程中处理，因此两件事严格地相继发生，但由于没有内存栅栏，是否有可能当 Consumer 处理该项目时，它看不到该项目的最终版本，因此具有未定义的行为？同步发生在 moodycamel::ConcurrentQueue 的幕后。正如名称（和文档）所示，它是一个线程安全队列。因此可以同时从不同线程写入和读取。喜怒无常的骆驼文档您发送shared_ptr的事实不会对这里产生任何影响。

c++ race-condition

回答 1 投票 0

根据之前的几个状态更新反应状态

假设我有两个反应状态：a和b const [a, setA] = useState(2) const [b, setB] = useState(10) 我想添加一个按钮，该按钮将根据它们之前的值更新它们：

javascript reactjs typescript react-hooks race-condition

回答 1 投票 0

Python中多个线程可以执行同一个实例方法吗？

如果我们有一个实例方法，它进行 api 调用并且不修改任何实例属性，它是否可以在多个线程中同时执行，而不会引起任何竞争条件？自从...

python multithreading race-condition

回答 1 投票 0

如何在不同调用之间的 React useEffect 挂钩中获取竞争条件标志？

这个问题可能是一个简单的问题，但我在搜索中没有找到任何内容。不同的 useEffect 挂钩调用如何共享获取竞争条件标志中的值？我的意思是，在...