我有一些(实体框架 4)代码,如下所示:
class QueueItem{
public bool Processed { get; set; }
// ... other fields
}
class QueueContext: System.Data.Entity.DbContext
{
public System.Data.Entity.DbSet<QueueItem> Queue { get; set; }
public void ProcessItems()
{
do
{
var item = Queue.FirstOrDefault(q => !q.Processed);
if(item == null) break;
ProcessItem(item);
item.Processed = true;
SaveChanges();
} while(true);
}
//...
}
我想将其更改为 ProcessItems 方法外部的多线程。事实上,我希望多个进程/appDomains 同时运行此代码。如何防止多个进程从队列中选择相同的项目?我可以使用系统范围的(命名的)互斥体,但我看到那些非常慢。我正在寻找某种原子的“拉动并标记为进行中”。我使用 SqlServerCE4 作为数据存储。