我无法找到这个错误的根源,因为当附加调试器时,它似乎没有发生。

修改集合;枚举操作可能无法执行

下面是代码。

这是Windows服务中的WCF服务器。只要有数据事件,服务就会调用NotifySubscribers()方法(随机间隔,但不经常——大约每天800次)。

When a Windows Forms client subscribes, the subscriber ID is added to the subscribers dictionary, and when the client unsubscribes, it is deleted from the dictionary. The error happens when (or after) a client unsubscribes. It appears that the next time the NotifySubscribers() method is called, the foreach() loop fails with the error in the subject line. The method writes the error into the application log as shown in the code below. When a debugger is attached and a client unsubscribes, the code executes fine.

您认为这段代码有问题吗?我需要使字典线程安全吗?

[ServiceBehavior(InstanceContextMode=InstanceContextMode.Single)]
public class SubscriptionServer : ISubscriptionServer
{
    private static IDictionary<Guid, Subscriber> subscribers;

    public SubscriptionServer()
    {            
        subscribers = new Dictionary<Guid, Subscriber>();
    }

    public void NotifySubscribers(DataRecord sr)
    {
        foreach(Subscriber s in subscribers.Values)
        {
            try
            {
                s.Callback.SignalData(sr);
            }
            catch (Exception e)
            {
                DCS.WriteToApplicationLog(e.Message, 
                  System.Diagnostics.EventLogEntryType.Error);

                UnsubscribeEvent(s.ClientId);
            }
        }
    }
    
    public Guid SubscribeEvent(string clientDescription)
    {
        Subscriber subscriber = new Subscriber();
        subscriber.Callback = OperationContext.Current.
                GetCallbackChannel<IDCSCallback>();

        subscribers.Add(subscriber.ClientId, subscriber);
        
        return subscriber.ClientId;
    }

    public void UnsubscribeEvent(Guid clientId)
    {
        try
        {
            subscribers.Remove(clientId);
        }
        catch(Exception e)
        {
            System.Diagnostics.Debug.WriteLine("Unsubscribe Error " + 
                    e.Message);
        }
    }
}

当前回答

可能发生的情况是,SignalData在循环过程中间接地更改了订阅者字典,并导致了该消息。您可以通过更改来验证这一点

foreach(Subscriber s in subscribers.Values)

To

foreach(Subscriber s in subscribers.Values.ToList())

如果我是对的,问题就会消失。

调用subscriber . values . tolist()复制订阅者的值。值赋给foreach开始时的单独列表。其他任何东西都不能访问这个列表(它甚至没有变量名!),所以在循环中没有东西可以修改它。

其他回答

可能发生的情况是,SignalData在循环过程中间接地更改了订阅者字典,并导致了该消息。您可以通过更改来验证这一点

foreach(Subscriber s in subscribers.Values)

To

foreach(Subscriber s in subscribers.Values.ToList())

如果我是对的,问题就会消失。

调用subscriber . values . tolist()复制订阅者的值。值赋给foreach开始时的单独列表。其他任何东西都不能访问这个列表(它甚至没有变量名!),所以在循环中没有东西可以修改它。

订阅者取消订阅时,您正在枚举期间更改订阅者集合的内容。

有几种方法可以解决这个问题,其中一种是改变for循环,使用显式的.ToList():

public void NotifySubscribers(DataRecord sr)  
{
    foreach(Subscriber s in subscribers.Values.ToList())
    {
                                              ^^^^^^^^^  
        ...

公认的答案在最坏的情况下是不精确和不正确的。如果在ToList()期间进行了更改,您仍然会得到一个错误。除了锁(如果您有一个公共成员,则需要考虑锁的性能和线程安全性)之外,一个合适的解决方案是使用不可变类型。

一般来说,不可变类型意味着一旦创建了它,就不能更改它的状态。 所以你的代码应该是这样的:

public class SubscriptionServer : ISubscriptionServer
{
    private static ImmutableDictionary<Guid, Subscriber> subscribers = ImmutableDictionary<Guid, Subscriber>.Empty;
    public void SubscribeEvent(string id)
    {
        subscribers = subscribers.Add(Guid.NewGuid(), new Subscriber());
    }
    public void NotifyEvent()
    {
        foreach(var sub in subscribers.Values)
        {
            //.....This is always safe
        }
    }
    //.........
}

如果您有一个公共成员,这可能特别有用。其他类总是可以对不可变类型进行foreach,而不用担心集合被修改。

好的,帮助我的是向后迭代。我试图从列表中删除一个条目,但向上迭代,它搞砸了循环,因为该条目不再存在了:

for (int x = myList.Count - 1; x > -1; x--)
{
    myList.RemoveAt(x);
}

在我看来,一个更有效的方法是另一个列表,你声明你把任何“要删除”的东西都放进去。然后,在完成主循环之后(不使用. tolist()),对“要删除的”列表执行另一个循环,删除每个条目。所以在你的课上你要加上:

private List<Guid> toBeRemoved = new List<Guid>();

然后你把它改成:

public void NotifySubscribers(DataRecord sr)
{
    toBeRemoved.Clear();

    ...your unchanged code skipped...

   foreach ( Guid clientId in toBeRemoved )
   {
        try
        {
            subscribers.Remove(clientId);
        }
        catch(Exception e)
        {
            System.Diagnostics.Debug.WriteLine("Unsubscribe Error " + 
                e.Message);
        }
   }
}

...your unchanged code skipped...

public void UnsubscribeEvent(Guid clientId)
{
    toBeRemoved.Add( clientId );
}

这不仅可以解决您的问题,还可以防止您从字典中创建一个列表,如果其中有很多订阅者,那么创建列表的代价非常昂贵。假设在任何给定迭代中要删除的订阅者列表低于列表中的总数,这样应该更快。当然,如果您在特定的使用情况中有任何疑问,请随意对其进行分析以确保情况属实。