我将尝试用一个简化的控制台应用程序示例来解释这个问题,但是真正的项目是一个 ASP.NET MVC3 应用程序。
具有以下表格:
想象以下场景:
- 用户创建报告(其中的一行,报告内容在
TestReport
哪里,是一个标志,表示报告是否已准备好进行处理);默认设置为,即未准备好。Text
string
Ready
bool
Ready
false
- 用户希望报告被处理,所以他提交它;
Ready
设置在true
这里。
如果报告还没有被处理,系统会提供一个机会来召回报告。所以,当报表被召回时,Ready
被设置为false
返回。相反,在处理报表时,会创建一行TestReportRef
,通过它的 引用报表Id
。
现在想象在同一时刻
- 用户想撤回报告;
- 报告被添加到进程列表中;
一旦这可能同时发生,就可能发生错误。那就是报告将有Ready
==false
并且将在TestReportRef
.
这是一个简单的控制台示例,说明如何发生这种情况:
var dc = new TestDataContext('my connection string');
dc.TestReport.InsertOnSubmit(new TestReport
{
Text = "My report content",
Ready = true //ready at once
});
dc.SubmitChanges();
Action recallReport = () =>
{
var _dc = new TestDataContext(cs);
var report = _dc.TestReport.FirstOrDefault(t => t.Ready);
if (report != null && !report.TestReportRef.Any())
{
Thread.Sleep(1000);
report.Ready = false;
_dc.SubmitChanges();
}
};
Action acceptReport = () =>
{
var _dc = new TestDataContext(cs);
var report = _dc.TestReport.FirstOrDefault(t => t.Ready);
if (report != null && !report.TestReportRef.Any())
{
Thread.Sleep(1000);
_dc.TestReportRef.InsertOnSubmit(new TestReportRef
{
FK_ReportId = report.Id
});
_dc.SubmitChanges();
}
};
var task1 = new Task(recallReport);
var task2 = new Task(acceptReport);
task1.Start();
task2.Start();
task1.Wait();
task2.Wait();
foreach (var t in dc.TestReport)
{
Console.WriteLine(string.Format("{0}\t{1}\t{2}", t.Id, t.Text, t.Ready));
}
foreach (var t in dc.TestReportRef)
{
Console.WriteLine("ref id:\t" + t.FK_ReportId);
}
Thread.Sleep(1000);
添加以确保任务将检查一个相同的情况。
给定的示例可能听起来很尴尬,但是,我希望它应该解释我正在处理的问题。
我怎样才能避免这种情况?使存储库单例似乎不是一个好主意。我应该只使用一些共享互斥锁(一个用于所有 Web 请求)来分隔写操作吗? 或者在这种情况下我应该使用什么模式?
这只是我所拥有的场景之一的简化示例。但是,在某些情况下,它可能会遇到类似的差异。我猜最好的办法是让这种交叉点成为不可能。