在线程之间共享局部变量是否安全（通过回调闭包）？

Question

我想做类似以下的事情 - 基本上我正在调用一个异步操作，它将在另一个线程中调用回调，我想等待它完成“内联”。我担心的是，跨线程（栏和事件）共享的更改变量可能由于存储在寄存器中而无法同步。如果它们是成员变量，我可以将它们标记为 volatile，但 volatile 不能用于在堆栈上创建的局部变量。我可以使用成员变量，但我认为它更干净，不会因为将其全部保留在本地而使我的课程变得混乱。

Bar bar = null;
ManualResetEvent event = new ManualResetEvent(false);

foo.AsyncOperation(new Action(()=>{    
    // This delegate will be called in another thread
    bar = ...
    event.Set();
}));

event.WaitOne(timeout);
// use bar

Answer 1

是的，它将正常工作。阅读这里

http://www.albahari.com/threading/part4.aspx

The following implicitly generate full fences:Setting and waiting on a signaling construct

在信号结构中包含ManualResetEvent。

如果您想知道full fence 是什么，请在同一页面中：

完整的栅栏 最简单的一种内存屏障是完整的内存 屏障（全围栏），可防止任何类型的指令重新排序 或在围栏周围缓存。调用 Thread.MemoryBarrier 会生成一个 完整的围栏；

Answer 2

我认为您的代码会起作用 - 即使它们只是堆栈变量（ManualReseetEvent 肯定不会），闭包也会提升到堆中。

但是你为什么不把所有的东西都放在 event.WaitOne() 之后的继续里面（块是 event.Set 被调用）？我认为这应该是处理这种情况的首选方式，这样你不会遇到麻烦（你根本不需要外块的Bar，你仍然可以使用MRE来检查）。

我会考虑使用 Task 对象将其转换为操作 - 这将一次性解决所有这些问题（例如从您的 AsyncOperation 返回一个任务）。然后您可以等待 Task 的结果并使用返回的 Bar ...

class Foo
{ 
 // ...
 private Task<Bar> AsyncOperation(Task<Bar> initializeBar)
 {
   return initializeBar
          .ContinueWith(
            bar => { 
                     /* do your work with bar and return some new or same bar */ 
                     return bar;
                   });
 }
}

并像这样使用它：

var task = foo.AsyncOperation(Taks.Factory.StartNew(() => { /* create and return a bar */ }));
var theBar = task.Result; // <- this will wait for the task to finish
// use your bar

PS：闭包基本上会将它们包装成一个类对象；） PPS：如果没有您的 AsyncOperation，我很难测试此代码，但它应该可以通过我所做的错误拼写/键入来解决模语法错误