获取集合已修改;枚举操作可能不会执行。例外获取收藏已修改;枚举操作可能不会执行。异常
代码:
public static string GetValue(List<StateBag> stateBagList, string name)
{
string retValue = string.Empty;
if (stateBagList != null)
{
foreach (StateBag stateBag in stateBagList)
{
if (stateBag.Name.Equals(name, StringComparison.InvariantCultureIgnoreCase))
{
retValue = stateBag.Value;
}
}
}
return retValue;
}
得到这个例外有一段时间没有时间每次都在这个地方。
堆栈跟踪:
在System.ThrowHelper.ThrowInvalidOperationException(ExceptionResource 资源)
在System.Collections.Generic.List`1.Enumerator.MoveNextRare()
的系统。 Collections.Generic.List`1.Enumerator.MoveNext()
at Tavisca.TravelNxt.Shared.Entities.StateBag.GetValue(List`1 stateBagList,String nam E)
@no一个我已经尝试了下面的代码,但仍然得到例外
代码:
class StateBag
{
public string Name;
public string Value;
}
class Program
{
static List<StateBag> _concurrent = new List<StateBag>();
static void Main()
{
var sw = new Stopwatch();
try
{
sw.Start();
Thread thread1 = new Thread(new ThreadStart(A));
Thread thread2 = new Thread(new ThreadStart(B));
thread1.Start();
thread2.Start();
thread1.Join();
thread2.Join();
sw.Stop();
}
catch (Exception ex)
{
}
Console.WriteLine("Average: {0}", sw.ElapsedTicks);
Console.ReadKey();
}
private static Object thisLock = new Object();
public static string GetValue(List<StateBag> stateBagList, string name)
{
string retValue = string.Empty;
if (stateBagList != null)
{
lock (thisLock)
{
foreach (StateBag stateBag in stateBagList)
{
if (stateBag.Name.Equals(name, StringComparison.InvariantCultureIgnoreCase))
{
retValue = stateBag.Value;
}
}
}
}
return retValue;
}
static void A()
{
for (int i = 0; i < 5000; i++)
{
_concurrent.Add(new StateBag() { Name = "name" + i, Value = i.ToString() });
}
}
static void B()
{
for (int i = 0; i < 5000; i++)
{
var t = GetValue(_concurrent, "name" + i);
}
}
}
传递给此方法的stateBagList可能会在其他地方更改。 –
我猜想这个方法可能是从1个线程调用的,而List则是从另一个线程同时修改的。 – Baldrick
我建议你只为stateBagList使用一个ConcurrentDictionary,并将它的Name(如果它是唯一的)键入。这将比连续搜索List更高效,并且将消除对自己的锁定逻辑的需要。 – Baldrick