wzt2017l 2017-10-25 08:38 采纳率: 100%
浏览 1076
已采纳

C# 创建连接块管道,为甚麽运行出错

这里是代码:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading.Tasks.Dataflow;
using System.IO;

namespace shujuliu
{
class Program
{
static void Main(string[] args)
{
var target = SetupPipeline();
target.Post(@"E:\临时文件\C#\assssss");//文件夹
Console.Read();

    }

    static IEnumerable<string> GetFileNames(string path)
    {
        foreach (var fileName in Directory.EnumerateFiles(path, "*.cs"))
        {
            //Console.WriteLine(fileName);
            yield return fileName;
        }
    }
    static IEnumerable<string> LoadLines(IEnumerable<string> filenames)
    {

        foreach (var filename in filenames)
        {


            using (FileStream stream = File.OpenRead(filename))
            {
                var reader = new StreamReader(stream);
                string line = null;
                while ((line = reader.ReadLine()) != null)
                {
                    yield return line; //这里出错,
                }
            }
        }

    }
    static IEnumerable<string> GetWords(IEnumerable<string> lines)
    {
        foreach (var line in lines)
        {
            string[] words = line.Split(' ', ';', '(', ')', '{', '}', '.', '\'', '.', '/', '\\');
            foreach (var word in words)
            {
                if (!string.IsNullOrEmpty(word))
                {
                    yield return word;
                }
            }
        }
    }
    static ITargetBlock<string> SetupPipeline()
    {
        var fileNamesForPath = new TransformBlock<string, IEnumerable<string>>(path => { return GetFileNames(path); });
        var lines = new TransformBlock<IEnumerable<string>, IEnumerable<string>>(files => { return LoadLines(files); });
        var words = new TransformBlock<IEnumerable<string>, IEnumerable<string>>(lines0 => { return LoadLines(lines0); });
        var display = new ActionBlock<IEnumerable<string>>(coll => { foreach (var s in coll) { Console.WriteLine(s); } });
        fileNamesForPath.LinkTo(lines);
        lines.LinkTo(words);
        words.LinkTo(display);
        return fileNamesForPath;
    }

}

}
这是控制台应用程序,编译没问题,
但是运行到 LoadLines(IEnumerable filenames)后,输出的 yield return line; 这个line会替换filename导致找不到文件。

  • 写回答

1条回答 默认 最新

  • threenewbee 2017-10-25 09:22
    关注
     static IEnumerable<string> LoadLines(IEnumerable<string> filenames)
        {
            return filenames.SelectMany(x => System.IO.Files.ReadAllLines(x));
        }
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥30 数值计算均差系数编程
  • ¥15 redis-full-check比较 两个集群的数据出错
  • ¥15 Matlab编程问题
  • ¥15 训练的多模态特征融合模型准确度很低怎么办
  • ¥15 kylin启动报错log4j类冲突
  • ¥15 超声波模块测距控制点灯,灯的闪烁很不稳定,经过调试发现测的距离偏大
  • ¥15 import arcpy出现importing _arcgisscripting 找不到相关程序
  • ¥15 onvif+openssl,vs2022编译openssl64
  • ¥15 iOS 自定义输入法-第三方输入法
  • ¥15 很想要一个很好的答案或提示