Parallel.ForEach выдает исключение при извлечении zip-файла

ZipFile явно задокументирован как негарантированный потокобезопасный для членов экземпляра. Это больше не упоминается на странице. Снимок за ноябрь 2016 г..

То, что вы пытаетесь сделать, невозможно сделать с этой библиотекой. могут существовать другие библиотеки, которые поддерживают несколько потоков на один zip-файл, но я бы этого не ожидал.

Вы можете использовать многопоточность для одновременного распаковывания нескольких файлов, но не для нескольких записей в одном ZIP-файле.

Параллельная запись/чтение не является хорошей идеей, так как контроллер жесткого диска будет выполнять запросы только один за другим. Имея несколько потоков, вы просто добавляете накладные расходы и ставите их в очередь без какой-либо выгоды.

Попробуйте сначала прочитать файл в память, это позволит избежать вашего исключения, однако, если вы проверите его, вы можете обнаружить, что он на самом деле медленнее из-за накладных расходов на большее количество потоков.

Если файл очень большой и распаковка занимает много времени, параллельное выполнение распаковки может улучшить скорость, однако чтение/запись ввода-вывода не улучшится. В любом случае, большинство библиотек декомпрессии уже являются многопоточными, поэтому, только если это не так, вы получите какой-либо прирост производительности от этого.

Редактировать: хитрый способ сделать библиотечный поток безопасным ниже. Это работает медленнее/на уровне в зависимости от zip-архива, что доказывает, что это не то, что выиграет от параллелизма.

Array.ForEach(Directory.GetFiles(@"c:\temp\output\"), File.Delete);

Stopwatch timer = new Stopwatch();
timer.Start();
int numberOfThreads = 8;
var clonedZipEntries = new List<ReadOnlyCollection<ZipArchiveEntry>>();

for (int i = 0; i < numberOfThreads; i++)
{
    clonedZipEntries.Add(ZipFile.Open(@"c:\temp\temp.zip", ZipArchiveMode.Read).Entries);
}
int totalZipEntries = clonedZipEntries[0].Count;
int numberOfEntriesPerThread = totalZipEntries / numberOfThreads;

Func<object,int> action = (object thread) =>
{
    int threadNumber = (int)thread;
    int startIndex = numberOfEntriesPerThread * threadNumber;
    int endIndex = startIndex + numberOfEntriesPerThread;
    if (endIndex > totalZipEntries) endIndex = totalZipEntries;

    for (int i = startIndex; i < endIndex; i++)
    {
        Console.WriteLine($"Extracting {clonedZipEntries[threadNumber][i].Name} via thread {threadNumber}");
        clonedZipEntries[threadNumber][i].ExtractToFile($@"C:\temp\output\{clonedZipEntries[threadNumber][i].Name}");
    }

    //Check for any remainders due to non evenly divisible size
    if (threadNumber == numberOfThreads - 1 && endIndex < totalZipEntries)
    {
        for (int i = endIndex; i < totalZipEntries; i++)
        {
            Console.WriteLine($"Extracting {clonedZipEntries[threadNumber][i].Name} via thread {threadNumber}");
            clonedZipEntries[threadNumber][i].ExtractToFile($@"C:\temp\output\{clonedZipEntries[threadNumber][i].Name}");
        }
    }
    return 0;
};


//Construct the tasks
var tasks = new List<Task<int>>();
for (int threadNumber = 0; threadNumber < numberOfThreads; threadNumber++) tasks.Add(Task<int>.Factory.StartNew(action, threadNumber));

Task.WaitAll(tasks.ToArray());
timer.Stop();

var threaderTimer = timer.ElapsedMilliseconds;



Array.ForEach(Directory.GetFiles(@"c:\temp\output\"), File.Delete);

timer.Reset();
timer.Start();
var entries = ZipFile.Open(@"c:\temp\temp.zip", ZipArchiveMode.Read).Entries;
foreach (var entry in entries)
{
    Console.WriteLine($"Extracting {entry.Name} via thread 1");
    entry.ExtractToFile($@"C:\temp\output\{entry.Name}");
}
timer.Stop();

Console.WriteLine($"Threaded version took: {threaderTimer} ms");
Console.WriteLine($"Non-Threaded version took: {timer.ElapsedMilliseconds} ms");


Console.ReadLine();