1

我已经从 SO 阅读了几个关于此问题的不同问题，但仍然无法使其正常工作。我public static string[] files = Directory.GetFiles(CurrentDirectory, "*.wav", SearchOption.AllDirectories);用来获取文件路径数组，然后将其传递给文件流。文件流所做的操作花费的时间太长，只有一个线程处理所有文件。所以我决定拆分数组并将这些较小的数组传递给不同的线程。

我使用的代码是从另一个 SO 问题中获得的，并用它来传递拆分数组，但它只适用于第一个数组中的一个文件，但我知道问题出在哪里：

var thing = from index in Enumerable.Range(0, files.Length) 
          group files[index] by index/600;
foreach(var set in thing)
    string.Join(";", set.ToArray());

（这不完全是我使用它的方式，我已经把它弄乱了，我不记得了。）这个问题是所有东西都被视为一个巨大的文件路径，我有一个 foreach 循环可以获取每个来自较小数组的文件，但它将其中的每个文件都视为一个，当搜索​​返回多个文件时抛出 filepathtoolong 异常。我的函数需要一个数组，然后用于foreach (string file in smallerArray)写入每个数组。我需要做的是将文件数组分解为 4 个较小的数组并启动新线程，new Thread(() => { DoWork(newArray); }).Start();但我尝试过的没有任何效果。

4

2 回答 2

5

所以我决定拆分数组并将这些较小的数组传递给不同的线程。

听起来你这样做很困难:)让框架为你处理它Parallel.ForEach：

Parallel.ForEach(files, file => 
{
    // Do stuff with one file
});
于 2012-08-01T18:33:41.647 回答
0

这是示例

    public static IEnumerable<IEnumerable<T>> Split<T>(this IEnumerable<T> source, int blockSize)
    {
        if (source == null)
            throw new ArgumentNullException("source");
        if (blockSize <= 0)
            throw new ArgumentException("blockSize = {0}".FormatWith(blockSize), "blockSize");
        var result = new List<IEnumerable<T>>();
        for (int blockStartIndex = 0; blockStartIndex < source.Count(); blockStartIndex += blockSize)
        {
            int blockStart = blockStartIndex;
            int blockEnd = blockStartIndex + blockSize - 1;
            IEnumerable<T> block = source.Where((x, i) => i >= blockStart && i <= blockEnd);
            result.Add(block);
        }
        return result;
    }

这是测试

    [Test]
    public void TestSplit()
    {
        var list = new[] {0, 1, 2, 3, 4, 5, 6, 7, 8, 9};
        IEnumerable<IEnumerable<int>> splitted = list.Split(10);
        Assert.That(splitted.Count(), Is.EqualTo(1));
        Assert.That(splitted.First().Count(), Is.EqualTo(10));

        splitted = list.Split(11);
        Assert.That(splitted.Count(), Is.EqualTo(1));
        Assert.That(splitted.First().Count(), Is.EqualTo(10));

        splitted = list.Split(9);
        Assert.That(splitted.Count(), Is.EqualTo(2));
        Assert.That(splitted.First().Count(), Is.EqualTo(9));
        Assert.That(splitted.ElementAt(1).Count(), Is.EqualTo(1));

        splitted = list.Split(3);
        Assert.That(splitted.Count(), Is.EqualTo(4));
        Assert.That(splitted.First().Count(), Is.EqualTo(3));
        Assert.That(splitted.ElementAt(1).Count(), Is.EqualTo(3));
        Assert.That(splitted.ElementAt(2).Count(), Is.EqualTo(3));
        Assert.That(splitted.ElementAt(3).Count(), Is.EqualTo(1));
    }
于 2012-08-01T18:35:54.157 回答