5

我已经组装了一个简单的应用程序，它监视文件创建事件，从文件内容创建一些对象，并进行一些处理。这是示例代码：

class Program
{
    private const string Folder = "C:\\Temp\\InputData";

    static void Main(string[] args)
    {
        var cts = new CancellationTokenSource();
        foreach (var obj in Input(cts.Token))
            Console.WriteLine(obj);
    }

    public static IEnumerable<object> Input(CancellationToken cancellationToken)
    {
        var fileList = new BlockingCollection<string>();

        var watcher = new FileSystemWatcher(Folder);
        watcher.Created += (source, e) =>
        {
            if (cancellationToken.IsCancellationRequested)
                watcher.EnableRaisingEvents = false;
            else if (Path.GetFileName(e.FullPath) == "STOP")
            {
                watcher.EnableRaisingEvents = false;
                fileList.CompleteAdding();
                File.Delete(e.FullPath);
            }
            else
                fileList.Add(e.FullPath);
        };
        watcher.EnableRaisingEvents = true;

        return from file in
                   fileList.GetConsumingEnumerable(cancellationToken)
               //.AsParallel()
               //.WithCancellation(cancellationToken)
               //.WithDegreeOfParallelism(5)
               let obj = CreateMyObject(file)
               select obj;
    }

    private static object CreateMyObject(string file)
    {
        return file;
    }
}

一切正常，但是当我取消注释 AsParallel （以及接下来的两行）时，它不会立即产生结果。这种延迟可能是由 PLINQ 分区引起的？但是，我希望此查询在将项目添加到 BlockingCollection 后立即生成项目。这可以使用 PLINQ 实现吗？

4

1 回答 1

2

这就是.WithMergeOptions(ParallelMergeOptions.NotBuffered)应该设计的。

于 2011-09-23T19:49:33.043 回答