异常异步读操作的已经在上StandardOutput流

Question

我试图用C＃来控制命令行应用程序的背景，这可以在这里下载进度：http://www.ti.com/litv/zip/spmc015b

这是电动机电压的应用控制，当我进入应用程序，如“b.exe -c 1”，控制台似乎是一种阻塞模型。此应用程序中的每个命令都以“＃”符号开头。见图片浏览：

http://i46.tinypic.com/zx5edv.jpg

我想要做的是，用StandardInput.WriteLine（ “STAT VOUT”）;测量电压。这将向控制台背景发送一个“stat vout”命令，并理想地返回一个电压值。在这张照片中，它会返回一些帮助提示。 Duing这一次，它仍然处于阻塞模式。

我想与StandardOutput.ReadLine返回消息（）;但失败了。如果ReadToEnd（）那么我的程序被冻结，因为这个应用程序永远不会返回到阻塞的标准控制台。

当我试图BeginOutputReadLine（）; OutputDataReceived事件可以真正从控制台获得消息返回，如在“stat [vout | vbus | fault”的图片中。但它限制在我的单线程中。

我现在的情况是，我使用System.Timers.Timers在WinForms和每一秒就会发出“STAT VOUT2”命令来读取电压，并希望得到返回值。

但是，System.Timers.Timers是异步的，所以当我在此定时器线程中调用BeginOutputReadLine（）时，它提示“异步读操作已在流上启动”。同时，正如我上面演示的那样，我不能使用像ReadLine（）这样的同步方法来获取值。

那么应该怎么办？我真的需要在多线程模式下运行这个命令行应用程序。

非常感谢，祝大家有一个愉快的周末。上04月28日19时18分CST

--update下面是相关的源代码：

其中WinFroms按钮将启动（）的SystemClock类，然后Timing.Measuring（）被执行每一秒。根据SystemClock，TimingController类将在一秒钟内同时调用GetVoltage（）和GetCurrent（），以测量电压和电流。

在测量类中，StandardInput.WriteLine（“stat vout2”）;从控制台应用程序获取电压，以及StandardInput.WriteLine（“stat cur”）;获取最新资讯。他们都使用BeginOutputReadLine（）来获得结果，因为StandardOutput不起作用。

我用isOutputObtained标志与表示，如果返回的数据。每次阅读完成后，我确实调用了CancelOutputRead（）;取消异步读取。

但它仍然给我的“异步读操作已在StandardOutput流进步”

public class SystemClock 
{ 
    TimingController Timing = new TimingController(); 
    private Timer TimerSystemClock; 

    public SystemClock() 
    { 
     TimerSystemClock = new Timer(); 
     TimerSystemClock.Interval = 1000; 
     TimerSystemClock.AutoReset = true; 
     TimerSystemClock.Elapsed += new ElapsedEventHandler(TimerSystemClock_Elapsed); 
     TimerSystemClock.Enabled = false; 
     Timing.ClockInstance = this; 
    } 

    public void Start() 
    { 
     TimerSystemClock.Enabled = true; 
    } 

    void TimerSystemClock_Elapsed(object sender, ElapsedEventArgs e) 
    { 
     Timing.Measuring(); 
    } 
} 

public class TimingController 
{ 
    // Get singleton of Measurement Class 
    Measurement Measure = Measurement.GetInstance();  

    public SystemClock ClockInstance 
    { 
     get { return Clock; } 
     set { Clock = value; } 
    } 

    private void Measuring() 
    { 
     CurrentVoltage = Measure.GetVoltage(); 
     CurrentCurrent = Measure.GetCurrent(); 
    } 
} 

public sealed class Measurement 
{ 
    // Singleton 
    public static readonly Measurement instance = new Measurement(); 
    public static Measurement GetInstance() 
    { 
     return instance; 
    } 

    private Process ProcMeasuring = new Process(); 
    double measureValue 
    bool isOutputObtained; 

    private Measurement() 
    { 
     ProcMeasuring.StartInfo.FileName = "b.exe"; 
     ProcMeasuring.StartInfo.Arguments = "-c 1"; 
     ProcMeasuring.StartInfo.WorkingDirectory = Directory.GetCurrentDirectory(); 
     ProcMeasuring.StartInfo.UseShellExecute = false; 
     ProcMeasuring.StartInfo.RedirectStandardInput = true; 
     ProcMeasuring.StartInfo.RedirectStandardOutput = true; 
     ProcMeasuring.StartInfo.RedirectStandardError = true; 
     ProcMeasuring.StartInfo.CreateNoWindow = true; 
     ProcMeasuring.OutputDataReceived += new DataReceivedEventHandler(MeasurementOutputHandler); 
    } 

    public double GetVoltage(Machine machine) 
    { 
     isOutputObtained = false; 

     ProcMeasuring.StandardInput.WriteLine("stat vout2"); 
     ProcMeasuring.BeginOutputReadLine(); 

     while (!isOutputObtained) 
     { 
      isOutputObtained = true; 
     } 

     return measureValue; 
    } 

    public double GetCurrent(Machine machine) 
    { 
     isOutputObtained = false; 

     ProcMeasuring.StandardInput.WriteLine("stat cur"); 
     ProcMeasuring.BeginOutputReadLine(); 

     while (!isOutputObtained) 
     { 
      isOutputObtained = true; 
     } 

     return measureValue; 
    } 

    private void MeasurementOutputHandler(object sendingProcess, DataReceivedEventArgs outLine) 
    { 
     if (!String.IsNullOrEmpty(outLine.Data) && (outLine.Data != "# ")) 
     {     
      measureCurrentValue = Convert.ToDouble(outLine.Data); 
      isOutputObtained = true; 

      ProcMeasuring.CancelOutputRead(); 
     } 
    } 
} 

Answer 1

错误例外，我认为你有两个选择。

如果是可以的，因为前一个时间太长，会错过一个样品，然后设置一个标志，表明您已经提供样品。

public class TimingController 
{ 
    // Get singleton of Measurement Class 
    Measurement Measure = Measurement.GetInstance();   

    bool isMeasuring = false; 

    public SystemClock ClockInstance 
    { 
     get { return Clock; } 
     set { Clock = value; } 
    } 

    private void Measuring() 
    { 
     if(isMeasuring) return; 

     isMeasuring = true; 
     CurrentVoltage = Measure.GetVoltage(); 
     CurrentCurrent = Measure.GetCurrent(); 
     isMeasuring = false; 
    } 
} 

如果不能确定会错过的区间，你可以尝试创建为每个调用一个新的工艺对象，而不是重用现有的过程。尽管这些命令需要很长时间才能完成，但这可能会创造出很多孩子。