我在以下代码中使用 .NET 4 中的 ConcurrentDictionary 和 ConcurrentQueue 类。
这段代码是线程安全的吗?如果不是,我怎样才能使其线程安全?
public class Page
{
public string Name {get; set; }
}
public class PageQueue
{
private ConcurrentDictionary<int, ConcurrentQueue<Page>> pages =
new ConcurrentDictionary<int, ConcurrentQueue<Page>>();
public void Add(int id, Page page)
{
if (!this.pages.ContainsKey(id))
this.pages[id] = new ConcurrentQueue<Page>();
this.pages[id].Enqueue(page);
}
public Page GetAndRemove(int id)
{
Page lp = null;
if(this.pages.ContainsKey(id))
this.pages[id].TryDequeue(out lp);
return lp;
}
}
Demo:
public class Demo
{
public void RunAll()
{
for (int i = 0; i < 10; i++)
Task.Factory.StartNew(() => Run());
}
public void Run()
{
PageQueue pq = new PageQueue();
pq.Add(1, new Page());
pq.GetAndRemove(1);
}
}
正如@Femaref 正确指出的那样,您的代码中存在一些缺陷。我建议您利用以下提供的许多方法并发字典使您的代码线程安全,而不需要lock
声明:
public class PageQueue
{
private ConcurrentDictionary<int, ConcurrentQueue<Page>> pages =
new ConcurrentDictionary<int, ConcurrentQueue<Page>>();
public void Enqueue(int id, Page page)
{
var queue = this.pages.GetOrAdd(id, _ => new ConcurrentQueue<Page>());
queue.Enqueue(page);
}
public bool TryDequeue(int id, out Page page)
{
ConcurrentQueue<Page> queue;
if (this.pages.TryGetValue(id, out queue))
{
return queue.TryDequeue(out page);
}
page = null;
return false;
}
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)