草庐IT

c++ - 我可以只用事件、互斥量和信号量实现公平的 "wait on multiple events"吗?

在只有事件[1]、互斥锁和信号量[2]的平台上,我可以创建一个公平的“等待多个事件”实现,当任何事件[3]发出信号/设置时返回。我假设现有的原语是公平的。[1]事件是具有4个操作的“标志”:Set()、Clear()、Wait()和WaitAndClear()。如果你在一个未设置的事件上等待(),你会阻塞直到有人设置()它。WaitAndClear()听起来像,但是原子的。所有服务员都被唤醒。[2]我认为系统不支持负值的信号量。[3]我说的是“事件”,但它可能是使用任何这些原语的新对象类型。 最佳答案 对于window,WaitFo

c++ - "black box"类型的标准布局保证的目的是什么?

C++标准指定mutex、atomics或conditinal_variable是标准布局类型。这个规范有什么好处?用户如何利用此属性?一般来说,如果知道一个类型是标准布局但不知道其实现细节,我能得到什么? 最佳答案 来自thisstandardlayoutreference:Standardlayouttypesareusefulforcommunicatingwithcodewritteninotherprogramminglanguages.例如,如果您构建一个C和C++混合应用程序,C结构将是标准布局,并且可以在用C编写的部

c++ - 多线程安全消息队列

这是我的本质:我有线程A,它定期检查消息并处理它们。线程B和C需要向A发送消息。当B和C或B或C试图向A发送消息而A正在处理消息并因此访问队列时,就会出现问题。这个问题通常是怎么解决的?谢谢 最佳答案 这通常使用mutexes解决,或其他多线程保护机制。如果您在Windows上工作,MFC会提供CMutexclass对于这个问题。如果您在posix系统上工作,posixapi会提供pthread_mutex_lock,pthread_mutex_unlock,andpthread_mutex_trylockfunctions.一些基

c++ - 如何分析 g++/std::mutex 下的锁争用?

问题是否有任何开源工具或是否有人有任何技术/代码来分析std::mutex争用的程度运行代码?我想在每个std::mutex实例的粒度(按时间或数量)计算锁争用的百分比。如果有一个不需要重新编码的嵌入式工具,那就更好了。我正在寻找一种适用于std::thread和g++的技术:在应用程序退出时,我想将互斥锁争用统计信息转储到日志文件中,这样我就可以在实际运行的上下文中监控线程代码的质量。注意我看过thisthread.不幸的是,答案要么需要大量现金,要么在Windows上运行。 最佳答案 我推荐像AMDCodeXL这样的东西或Int

c++ - 在共享模式下锁定的 std::shared_mutex 上调用解锁

C++17引入了std::shared_mutex类型。我一直在查看CppReference上的文档对产生未定义行为的情况特别感兴趣。在通读两种解锁方法(一种用于释放独占所有权,一种用于释放共享所有权)时,我注意到文档有一次有点含糊。对于std::shared_mutex::unlock_shared,文档说明(强调我的):Themutexmustbelockedbythecurrentthreadofexecutioninsharedmode,otherwise,thebehaviorisundefined.它清楚地表明调用unlock_shared必须先调用lock_shared因

c++ - 当互斥锁/解锁深埋在函数调用中时,我是否需要栅栏或屏障或其他东西?

我最近了解到,编译器将通过重新排列指令来优化您的代码,并且这可以通过使用屏障来控制。IIRC,锁定互斥量构成屏障,解锁互斥量也构成屏障,以防止临界区内的代码泄露。因此pthread_mutex_lock和pthread_mutex_unlock必须隐含地成为这些“障碍”。如果我有这样一个包装互斥体的类怎么办?classIMutex{public:virtualvoidlock()=0;virtualvoidunlock()=0;};在我看来,编译器不会知道我在lock()中调用pthread_mutex_lock(),在unlock()中调用pthread_mutex_unlock()

c++ - 为什么 std::timed_mutex::try_lock_for 不起作用?

我在Ubuntu12.04中使用gcc-4.8.1(configure:./configure--prefix=/usr/local)编译了以下代码,但是当我运行它时,它没有工作。它没有停下来等待互斥量。它返回false,并输出“Helloworld!”命令:g++-std=c++11main.cpp-omain-pthread当我用gcc-4.6(apt-getinstallg++)编译时,效果很好。程序等了大概十秒,输出了“Helloworld!”#include#include#include#includestd::timed_mutextest_mutex;voidf(){t

c++ - 我可以在 C++ 中仅使用 std::atomic 而不使用 std::mutex 安全地跨线程共享变量吗?

我制作了一个在多核上计算素数的程序。(请忽略该算法并非完全有效,这里将数字0和1视为质数。目的只是练习使用线程。)变量taken(接下来要测试的数字)正在8个线程之间共享。问题是它可以由一个线程递增,紧接着由另一个线程递增,并在它已经递增两次(或更多次)时被它们读取,因此可以跳过一些值,这是一件坏事。我以为它可以通过使用std::atomic_uint作为变量类型来解决,但我显然错了。有什么方法可以在不需要使用std::mutex的情况下解决这个问题,因为我听说它会导致相当大的开销?源代码:#include#include#include#include#include#include

c++ - 互斥实现可以互换吗(独立于线程实现)

是否所有互斥量实现最终都调用相同的基本系统/硬件调用-这意味着它们可以互换?具体来说,如果我正在使用__gnu_parallel算法(使用openmp)并且我想使它们调用的类成为线程安全的,我可以使用boost::mutex用于锁定?还是我必须编写自己的互斥锁,例如描述的here//Anopenmpmutex.Canthisbereplacedwithboost::mutex?classMutex{public:Mutex(){omp_init_lock(&_mutex);}~Mutex(){omp_destroy_lock(&_mutex);}voidlock(){omp_set_l

c++ - 从 std::call_once 抛出异常

C++标准对使用抛出异常的函数执行std::call_once(§30.4.4.2/2)作了如下说明:2/Effects:Anexecutionofcall_oncethatdoesnotcallitsfuncisapassiveexecution.Anexecutionofcall_oncethatcallsitsfuncisanactiveexecution.AnactiveexecutionshallcallINVOKE(DECAY_-COPY(std::forward(func)),DECAY_COPY(std::forward(args))...).Ifsuchacallto