2

我有一个 Parallel foreach 函数，它创建一个类的新实例，操作图片并将其保存到磁盘...

然而，大约 400 次中的 4 次，图片被保存到磁盘，但没有被操纵，我的理论是，当它发生时，我班级中存在的一些属性是空的，当它们不应该......

4 个（有时是 3 个）错误大多发生在并行循环的前 10 个图像中。

没有错误消息，它只是跳过了我的一些代码，出于某种原因......我的断点在并行时不起作用，因此很难调试。

关于如何进行/调试/修复的任何建议？

要求的代码

    private static void GenerateIcons(Effects effect)
    {
        DirectoryInfo dir = new DirectoryInfo(HttpContext.Current.Server.MapPath(@"~\Icons\Original\"));

        FileInfo[] ff = dir.GetFiles();

        string mappath = HttpContext.Current.Server.MapPath(@"~\Icons\");

        List<string> paths = new List<string>();

        string ids = GetAllEffectIds(effect.TinyUrlCode);

        Parallel.ForEach(ff, item =>
        {
            if (!File.Exists(mappath + @"Generated\" + ids + "-" + item.Name))
            {
                paths.Add(mappath + @"Generated\" + ids + "-" + item.Name);
                ApplyEffects f = new ApplyEffects(effect, item.Name, mappath);
                f.SaveIcon();


            }
        });
        //Zip icons!
        ZipFiles(paths, effect.TinyUrlCode, ids, effect.General.Prefix);

    }
4

3 回答 3

1

List<T>我的理论是，由于不是线程安全的，您的路径列表没有正确更新。本质上，如果两个线程同时尝试将一个项目添加到列表中，则可能会发生任何数量的奇怪事情，例如结果列表中缺少 4 个项目。尝试使用lock 语句。

Parallel.ForEach(ff, item =>
{
    if (!File.Exists(mappath + @"Generated\" + ids + "-" + item.Name))
    {
        lock(paths) 
        {
            paths.Add(mappath + @"Generated\" + ids + "-" + item.Name);
        }
        ApplyEffects f = new ApplyEffects(effect, item.Name, mappath);
        f.SaveIcon();
    }
});
于 2012-06-20T13:00:33.447 回答
1

您可以以更实用的风格重新编写它，以希望消除线程问题：

private static void GenerateIcons(Effects effect)
{
    var dir     = new DirectoryInfo(HttpContext.Current.Server.MapPath(@"~\Icons\Original\"));
    var mappath = HttpContext.Current.Server.MapPath(@"~\Icons\");
    var ids     = GetAllEffectIds(effect.TinyUrlCode);

    var filesToProcess = dir
        .EnumerateFiles()
        .AsParallel()
        .Select(f => new { info = f, generated = File.Exists(mappath + @"Generated\" + ids + "-" + f.Name) })
        .ToList();

    Parallel.ForEach(filesToProcess.Where(f => !f.generated), file =>
    {
        new ApplyEffects(effect, file.info.Name, mappath).SaveIcon();
    });

    //Zip icons!
    ZipFiles(filesToProcess.Select(f => f.info), effect.TinyUrlCode, ids, effect.General.Prefix);
}
于 2012-06-20T13:35:01.470 回答
0

  1. 你检查过非并行版本吗？

  2. 您是否使用了任何未标记为线程安全的 API 函数？

要回答 1)，互斥锁锁定整个函数并测试错误。

要回答 2）减少互斥锁中的代码量，直到找到有问题的函数。你可以通过二等分来做到这一点。

ConcurrentBag<T>是一个线程安全的容器。

于 2012-06-20T12:57:04.447 回答