我有一个传感器,它以n Hz的速度向线程中的共享内存写入数据(比如每秒10Hz=10次)。一个单独的线程正在读取这些数据,并使用它来获取一些结果。读取器线程的频率不同。它可以更慢,例如每秒8次,也可以更快,例如每秒15次,这取决于正在计算的内容。读取器线程只是从共享内存中读取数据。它不修改数据(只对其进行处理以获得某些结果),也不向共享内存写入任何内容。整个过程运行得非常整洁。我不关心同步,因为读取器只是在需要的时候读取共享内存中的内容(它轮询数据)。如果在两次读取之间,共享内存的内容发生更改,则读取器将使用新数据。如果在两次读取之间,共享内存的内容没有改变(如果读取器比写入器快得多),那么读取器只使用共享内存中的任何数据。
现在,我的同事告诉我使用互斥来同步对共享内存的访问,但我不同意。原因是,如果我使用互斥锁来控制访问,写入器写入共享内存的频率将会有所降低(当读线程锁定互斥锁并写入时)。在未来,我们将有更多的读线程,我担心写线程写入共享内存的频率将进一步降低,因为将有更多的线程竞争互斥锁。
我知道竞态条件等,但我感觉竞态条件以及上面给出的大量例子以及其他网站考虑的场景与我的不同:例如,当两个线程正在读取和处理银行余额,其中一个线程读取速度较慢或较快,余额以$2000而不是$1000的erroneous...resulting结束。然而,在我的例子中,“银行余额”-要共享的数据是由传感器生成的。值的任何变化都是由物理原因造成的,要共享的数据值永远不会跳跃这么大的量。
更多细节:该传感器是一个距离测量传感器。它可以在一秒内测量10次距离。假设t=1.0s处的距离为10 to,并将其写入内存。读取器读取显示为10 The的共享内存。现在,如果实际距离在阅读器读取或处理数据时碰巧发生变化,它将是10.1厘米,或者因为距离永远不会有很大的跳跃。在下一次轮询中,读者将读取10.1厘米的距离(假设物体是静止的)。通过这种方式,我的写入器线程可以在不等待互斥锁被解锁的情况下尽可能快地写入。
我的推理有缺陷吗?我能想到的唯一问题是,如果我的写线程和读线程试图完全同时访问内存。但是,调度器应该在指令之间切换,对吧?也就是说,它只是伪并行处理,对吗?这意味着它们不能同时访问内存,对吗?
发布于 2016-03-24 08:02:44
我不知道这个答案是否应该是一个评论,如果是,请让我知道……
您可以尝试实现循环缓冲区。这样,写入器就有了一个指针,它只是在缓冲区中旋转并继续写入。读者也有同样的想法,只是要“落后于”作者。
这意味着当写入器写入一些值时,它必须增加变量,该变量说明有多少数据可用。当读取器读取样本时,它必须减少这个变量。这些操作必须锁定在互斥锁中。虽然i++和i--是原子操作,但在多核系统上,这仍然会带来麻烦,我很难发现这一点。
所以,是的,你确实需要互斥锁,但因为只需要一个变量,所以它不会让你的整个程序变慢太多……
发布于 2016-03-24 08:04:03
这取决于您的实现是否使用抢占任务(例如中断)。可能是读线程正在读取值,并且在读过程中被写线程中断。在你的例子中,我假设这个值只是一个整数,因此它不是那么关键。只需确保在读取线程中每次执行时只读取一次数据(请参阅原子操作)。如果该值大于一个寄存器值。您可以通过使用队列和多级缓冲区来避免互斥。但是这会增加你的内存使用量。在你的例子中:如果你的数据大于一个整数,我建议使用三重缓冲内存。在这种情况下,您拥有三个缓冲区,值被写入第一个缓冲区,在完成后,缓冲区与第二个缓冲区交换,而您的读取线程可以读取第三个缓冲区。
发布于 2016-03-24 08:29:37
在你的例子中,问题是读取器可以在写变量的同时读取,问题只是写,所以我建议你使用原子操作来写,这样你就不需要互斥锁了。如果数据是对齐的(参见Read and Write atomic operation implementation in the Linux Kernel),那么读操作是原子的,我不确定写操作,但可能不是,所以让我们来看看我们能做什么:
在C++中,STL提供了一些材料来保证操作是原子的请参阅:http://en.cppreference.com/w/c/atomic在C中,我发现在标准http://www.gnu.org/software/libc/manual/html_node/Atomic-Types.html中定义的sig_atomic_t类型保证了读取和写入的原子操作,它应该在没有互斥锁的情况下完成这项工作。
https://stackoverflow.com/questions/36195399
复制相似问题