异常 标准输出流上的异步读取操作已在进行中

本文关键字:操作 进行中 读取 异步 标准输出流 异常 | 更新日期: 2023-09-27 18:32:36

我正在尝试使用C#来控制命令行应用程序背景,可以在此处下载:http://www.ti.com/litv/zip/spmc015b

这是一个用于电机电压控制的应用程序,当我进入应用程序时,像"b.exe -c 1",控制台似乎是一种阻塞模型。此应用程序中的每个命令都以"#"符号开头。在这里查看图片:

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

我想做的是,使用StandardInput.WriteLine("stat vout"(来测量电压。这将向控制台后台发送"stat vout"命令,理想情况下返回电压值。在此图片中,它返回了一些帮助提示。由于一直以来,它仍然处于阻止模式。

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

当我尝试 BeginOutputReadLine((;OutputDataReceived 事件可以真正获取控制台返回的消息,就像"stat [vout|vbus|fault"的图片一样。但它在我的单线程程序中受到限制。

我目前的情况是,我在WinForms中使用System.Timers.Timers,每秒都会发送一个"stat vout2"命令来读取电压,并希望得到返回值。

但是,System.Timers.Timers 是异步的,因此当我在此计时器线程中调用 BeginOutputReadLine(( 时,它提示"已在流上启动异步读取操作"。同时,正如我上面所演示的,我不能使用 ReadLine(( 等同步方法来获取值。

那么我现在该怎么办?我确实需要在多线程模式下运行此命令行应用程序。

非常感谢,祝大家周末愉快。

-

-CST 4 月 28 日 19:18 更新以下是相关的源代码:

其中一个 WinFroms 按钮将 Start(( SystemClock 类,然后每秒执行一次 Timing.Measuring((。TimemingController 类将根据 SystemClock 在一秒钟内同时调用 GetVoltage(( 和 GetCurrent((,以测量电压和电流。

在测量类中,StandardInput.WriteLine("stat

vout2"(;从控制台应用程序获取电压,以及 StandardInput.WriteLine("stat cur"(;获取电流。他们都使用 BeginOutputReadLine(( 来获取结果,因为 StandardOutput 不起作用。

我使用 isOutputGot 标志来指示是否返回数据。每次读取完成后,我都会调用 CancelOutputRead((;以取消异步读取。

但它仍然给了我"标准输出流上已经在进行异步读取操作"的错误异常

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();
        }
    }
}

异常 标准输出流上的异步读取操作已在进行中

我认为你有两个选择。

如果因为前一个样本

花费的时间太长而错过样本是可以的,那么设置一个标志来指示您已经在采样。

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;
    }  
} 

如果不能错过间隔,可以尝试为每个调用创建一个新的进程对象,而不是重用现有进程。如果命令需要很长时间才能完成,这可能会创建很多孩子。