while循环中的字典和删除字典中的项

本文关键字：字典 删除 循环 while | 更新日期: 2023-09-27 18:11:47

我有一个字典，如果字典中的项通过了所有处理，我想删除它。

            var dictEnum = dictObj.GetEnumerator();
            while (dictEnum.MoveNext())
            {
                 Parallel.ForEach(dictObj, pOpt, (KVP, loopState) =>
                 {
                      processAndRemove(KVP.Key);
                 });
            }
            private void processAndRemove(string keyId)
            {
               try
               {
               <does stuff>
               dictObj.Remove(keyId);
               } catch(exception ex) {
                 ...
                 <does not remove anything, wants to retry until it doesn't fail>
               }
            }

我希望循环继续处理字典中所有剩余的(未删除的)项。

然而，我得到一个错误。当我运行这段代码的简单版本时，我得到一条消息:

Collection被修改;枚举操作不能执行

是否有一种方法可以使用字典来做到这一点?

更新:

只是为了给更多的背景。这样做背后的思想是，如果dictObj中还有剩余的项，循环将继续运行。所以如果我从10和8开始，我想重新运行没有通过的2，直到它们通过。

while循环中的字典和删除字典中的项

正如Jalayn所说，当你枚举集合时，你不能从集合中删除它。您必须重写代码，以便将其添加到另一个集合中，然后枚举该集合并从原始集合中删除项。

类似:

var toRemove = new Dictionary<int, string>() //whatever type it is
Parallel.ForEach(dictObj, pOpt, (KVP, loopState) =>
{
    toRemove.Add(KVP);
});
foreach (var item in toRemove)
{
    dictObject.Remove(item.Key);
}

如果在同一时间遍历一个项，则不能从集合中删除该项。然而，你可以做的是将你想要删除的所有元素存储在一个单独的集合中。

然后，当您完成枚举时，您可以遍历列表以从原始集合中删除每个项。

或者，查看从c#字典中删除与谓词匹配的多个项的最佳方法?它很漂亮。接受的答案摘录，由用户@JaredPar提供:

foreach ( var s in MyCollection.Where(p => p.Value.Member == foo).ToList() ) {
  MyCollection.Remove(s.Key);
}

我认为你不能用字典来做。相反，你可以做类似Dictionary.Values.ToList()的事情，删除你想要的，然后调和差异。

这个问题有更多关于它的信息。枚举操作不能执行

开始第二个集合，并向其中添加您想要保留的值。

为什么要显式调用GetEnumerator()而不是使用foreach ?foreach语句可以帮助您。在本例中，您在循环中使用MoveNext()，但您从未读取Current属性。

看起来你试图在dictObj上使用Parallel.ForEach，但你确定它是线程安全的类型吗?可能不会。它是什么类型的?

最后，错误文本说明了一切。

从我与Jeppe Stig Nielsen的对话中产生了尝试ConcurrentDictionary的想法

这是我的测试代码，我能够从字典中删除项目(从并行中)。Foreach循环)和while循环一直持续到count == 0 or the retryAttempts > 5 

    public static ConcurrentDictionary<string, myRule> ccDict= new ConcurrentDictionary<string, myRule>();
       try
        {
            while (ccDict.Count > 0)
            {
                Parallel.ForEach(ccDict, pOptions, (KVP, loopState) =>
                {
                    //This is the flag that tells the loop do exit out of loop if a cancellation has been requested
                    pOptions.CancellationToken.ThrowIfCancellationRequested();
                    processRule(KVP.Key, KVP.Value, loopState);
                }); //End of Parallel.ForEach loop
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message.ToString());
            Console.ReadLine();
        }
    public static int processRule(string rId, myRule rule, ParallelLoopState loopState)
    {
        try
        {
            if (rId == "001" || rId == "002")
            {
                if (rId == "001" && ccDict[rId].RetryAttempts == 2)
                {
                    operationPassed(rId);
                    return 0;
                }
                operationFailed(rId);
            }
            else
            {
                operationPassed(rId);
            }
            return 0;
        }
        catch (Exception ex)
        {
            Console.WriteLine("failed : " + ex.Message.ToString());
            return -99;
        }
    }
    private static void operationPassed(string rId)
    {
        //Normal Operation
        ccDict[rId].RulePassed = true;
        ccDict[rId].ExceptionMessage = "";
        ccDict[rId].ReturnCode = 0;
        Console.WriteLine("passed: " + rId + " Retry Attempts : " + ccDict[rId].RetryAttempts.ToString());
        rule value;
        ccDict.TryRemove(rId, out value);
    }
    private static void operationFailed(string ruleId)
    {
        //This acts as if an EXCEPTION has OCCURED
        int retryCount = 0;
            ccDict[rId].RulePassed = false;
            ccDict[rId].RetryAttempts = ccDict[rId].RetryAttempts + 1;
            ccDict[rId].ExceptionMessage = "Forced Fail";
            ccDict[rId].ReturnCode = -99;
            ccDict.TryUpdate(rId, ccDict[rId], ccDict[rId]);
            if (ccDict[rId].RetryAttempts >= 5)
            {
                Console.WriteLine("Failed: " + rId + " Retry Attempts : " + ccDict[rId].RetryAttempts.ToString() + " : " + ccDict[rId].ExceptionMessage.ToString());
                cancelToken.Cancel();
            }
    }
    public class myRule
    {
        public Boolean RulePassed = true;
        public string ExceptionMessage = "";
        public int RetryAttempts = 0;
        public int ReturnCode = 0;

        public myRule()
        {
            RulePassed = false;
            ExceptionMessage = "";
            RetryAttempts = 0;
            ReturnCode = 0;
        }
    }
相关文章：