Dal*_*pić 1 .net vb.net multithreading synchronization
我一直在阅读很多各种博客和StackOverflow问题,试图找到我的问题的答案,最后我找不到任何东西,所以我想自己问这个问题.
我正在构建一个应用程序,其中我有一个长时间运行的工作线程,它执行一些操作并在运行期间将一些结果放入变量中.工作线程一直在工作,并不断产生一些结果,我只对结果的"当前"值感兴趣.在某些时候,另一个线程将获得工作线程运行的"当前"结果并对其执行某些操作.
这样的工作线程的简单实现可以这样做:
Public Class Worker
Private _result As DateTimeOffset?
Public ReadOnly Property Result As DateTimeOffset?
Get
Return _result
End Get
End Property
Public Sub ThreadMethod()
' Do something
_result = x
' .
' .
_result = y
' .
' .
' etc
End Sub
End Class
Run Code Online (Sandbox Code Playgroud)
现在让我说我有一个想要消费结果的消费者:
Public Class Consumer
Private _worker As Worker
Public Sub Consume()
Dim result As DateTimeOffset?
While True
' Do some work on your own
' .
' .
' Get current result
result = _worker.Result
' Do something with result
End While
End Sub
End Class
Run Code Online (Sandbox Code Playgroud)
据我所知,编译器的工作原理似乎是合乎逻辑的,编译器可以进行Property Result
内联,然后将_result
变量优化为寄存器,只是一遍又一遍地读取相同的值.在C#中,我可以将结果标记为,volatile
并且这(我认为)会阻止此类优化,但VB.NET中不存在该关键字.我能想出的最接近的解决方案是使用Volatile.Write
和Volatile.Read
方法.但是这些方法不能用于Nullable(Of DateTimeOffset)
.
注1:虽然这个问题似乎与弱/强内存模型和内存障碍的使用有关,但我不认为它们在这种情况下会产生任何影响.如果有人声称Thread.MemoryBarrier()
会强制读/写来自内存,这对我来说也是一个很好的解决方案.
注2:我知道还有其他方法可以解决这个问题,但我想知道解决方案是否可行(如果问题甚至存在,我甚至不确定)对于所描述的场景.
使用Thread.MemoryBarrier
仅确保该线程中的内存访问顺序.你有两个线程访问同一个变量,所以你需要更多的保护.
varable不是原子的,因此如果不同步访问,最终可能会读取部分写入的值.您可以为属性创建同步的getter和setter,然后使用worker线程中的setter来设置值,而不是设置支持变量.
Private _result As DateTimeOffset?
Private _sync as New Object()
Public Property Result As DateTimeOffset?
Get
SyncLock _sync
Return _result
End SyncLock
End Get
Set(ByVal value as dateTimeOffset?)
SyncLock _sync
_result = Value
End SyncLock
End Set
End Property
Run Code Online (Sandbox Code Playgroud)