- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
假设我们有这样一个类:
public class Foo
{
private Bar bar = new Bar();
public void DoStuffInThread1()
{
var old = Interlocked.Exchange(ref bar,new Bar());
//do things with old
//everything is fine here, I'm sure I have the previous bar value
}
public void OtherStuffFromThread2()
{
//how do I ensure that I have the latest bar ref here
//considering mem cahces etc
bar.Something();
}
}
假设我们有两个线程,一个在 DoStuffInThread1
上运行,另一个在 OtherStuffFromThread2
上运行。
如何确保线程 2 始终看到最新的 bar
?volatile 没有帮助。而且我不想要老派的锁。必须有一种方法来读取带有内存屏障/以某种方式互锁的 bar 的正确值吗?
最佳答案
你错过了重点......
除非你这样做:
public void OtherStuffFromThread2()
{
while (true)
{
//how do I ensure that I have the latest bar ref here
//considering mem cahces etc
bar.Something();
}
}
这是非常不可能的事情,几乎所有您可以在 OtherStuffFromThread2()
上使用的等待线程 1 准备就绪的方法都会导致隐式内存障碍...参见示例 Memory barrier generators一些导致内存障碍的构造......
所以:
public void OtherStuffFromThread2()
{
Thread.Sleep(Timespan.FromMinutes(1));
// Implicit MemoryBarrier here :-)
//how do I ensure that I have the latest bar ref here
//considering mem cahces etc
bar.Something();
}
如果你真的想读一个变量的值,你可以读一个volatile变量然后读你的变量(或者读同一个volatile变量两次)。为什么?因为 volatile 读取会导致获取语义,这意味着它无法通过后续内存操作重新排序,请参阅 https://msdn.microsoft.com/en-us/library/aa645755(v=vs.71).aspx :
A read of a volatile field is called a volatile read. A volatile read has "acquire semantics"; that is, it is guaranteed to occur prior to any references to memory that occur after it in the instruction sequence.
所以如果你这样做:
private static int myuselessvolatilefieldthatcanbestatic;
private int thefieldiwanttoread;
然后
var useless = myuselessvolatilefieldthatcanbestatic;
var iwanttoknow = thefieldiwanttoread;
thefieldiwanttoread
将包含一个值,该值将在 对 myuselessvolatilethatcanbestatic
的新读取完成后读取。
请注意,如果没有同步原语,将很难知道 myuselessvolatilefieldthatcanbestatic
何时完成 :-),但是:
while (true)
{
var useless = myuselessvolatilefieldthatcanbestatic;
var iwanttoknow = thefieldiwanttoread;
// Some code goes here
}
现在至少你可以使用你的while (true)
:-)
关于c# - Interlocked.Exchange 后无锁读取值?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29107314/
我希望以原子方式递增静态变量,同时以无锁方式将新值分配给实例字段。目标是让每个对象在创建时获得一个唯一的、递增的 ID,这样两个对象就不可能获得相同的 ID。 下面的代码能实现吗? class MyC
我在优化程序时遇到了一些奇怪的性能结果,这些结果显示在以下 BenchmarkDotNet 基准测试中: string _s, _y = "yo"; [Benchmark] public void E
很抱歉问了这么长的问题,但是有 Jon Skeet 的引用资料,所以对某些人来说可能是值得的。 简而言之: Interlocked.Read/Interlocked.Exchange 在 Mono 框
在我阅读 ReaderWriterLockSlim 时锁机构,There was this guy谁建议 Interlock函数可用于更精细的锁定 另外,我发现 here马克的另一个回答: ...Wr
假设我有一个变量“counter”,并且有几个线程使用Interlocked访问和设置“counter”的值,即: int value = Interlocked.Increment(ref coun
Interlocked.CompareExchange() 方法 ( docs ) 粗略地说: “我有一个变量,我想我知道它当前有什么值。如果我是对的,请将值更改为那个”。 关键是这个方法可以用来在多
例子: Thread a: Interlocked.Increment(ref x); Thread b: int currentValue = x; 假设线程 b 在线程 a 之后执行,线程 b
我们有一个方法可以维护我们应用程序中所有事件的全局序列索引。由于它是网站,因此预计具有线程安全的这种方法。线程安全的实现如下: private static long lastUsedIndex =
我见过很多不错的对象池实现。例如:C# Object Pooling Pattern implementation . 但似乎线程安全的总是使用锁,从不尝试使用 Interlocked.* 操作。 编
是 Interlocked.Increment(ref x)比 x++ 快或慢对于各种平台上的整数和多头? 最佳答案 它较慢,因为它强制操作以原子方式发生,并且充当内存屏障,消除了处理器围绕指令重新排
我有一个应用程序,它不断地(+-100 毫秒)从 PLC 读取订单,然后将它们放入模型中,然后由多个客户端读取。为此,我使用了 lock 语句。 订单阅读线程: lock (model) { //up
我们有一个并发的多线程程序。我如何使样本数每次增加 +5 间隔? Interlocked.Increment 是否有间隔过载?我没有看到它列出。 Microsoft Interlocked.Incre
作为一个线程菜鸟,我正在尝试找到一种不锁定对象的方法,允许我将线程池任务排入队列,这样它的最大并行度 = 1。 这段代码会按照我的想法行事吗? private int status; private
这仅涉及 Microsoft/Visual Studio 和 Intel/AMD 特定实现。 比如说,如果声明一个全局变量: volatile __declspec(align(16)) ULONG
我有几个简单的(希望是)问题,我一直无法找到答案 - 假设我有多个线程可以访问的对象 a、b。 Interlocked.Exchange(ref a, b) 如果“b”不是 volatile 的,这个
我正在编写一个需要使用 Interlocked 的通用类。 T test1, test2; Interlocked.Exchange(ref test1, test2); 这不会编译。所以我是否被迫使
我有一些遗留代码使用 Interlocked.Equals 来比较值。这些值可以是两个 bool 值,也可以将一个结构数组与 null 进行比较。 Resharper 提示 Interlocked.E
如果我要使用某种算法,在 C++ 中对变量使用 InterlockCompareExchange 操作来确定特定线程是否正在写入一组数据(通过创建我自己的小锁),我如何确保如果数据存储在 i7 上的
假设我们有这样一个类: public class Foo { private Bar bar = new Bar(); public void DoStuffInThread1()
来自文档 here :“此类的方法有助于防止在线程正在更新可由其他线程访问的变量时调度程序切换上下文时可能发生的错误...” 此外,对 this question 的回答声明“互锁方法在任何数量的内核
我是一名优秀的程序员,十分优秀!