0

我在另一个问题中提到,我正在开发一个带有进度条等的 ffmpeg 解析器。

以下问题不是 100% 可重现的。当我用我的程序转换视频文件时,大多数时候一切正常。它在较小的文件(约 100MB 输出)上完美运行,但在较大的文件(约 1GB 输出)上,有时 gui 会冻结,但 ffmpeg 正在运行(调试器仍然从 ffmpeg 获取输出并显示它,所以表单线程确实不要冻结,只有控制台的 gui)

我还意识到 ffmpeg 完成了它必须做的工作,没有任何可能导致冻结的错误。

如果我在调试环境之外运行它,该表单也会冻结。

解析工作在一个额外的线程上来处理 ffmpeg 异步的输出。

我认为这个线程会冻结,并且主程序将在 ffmpeg 完成后挂断,因为解析器会收到command == null与主程序相关的消息,表明转换已完成。我实际上不能这么说,因为 atm 我无法重现冻结以及上次我忘记提及调试器是否输出"======== #"

您可以在此处找到作为 ConvertApp.zip的源代码(在调试文件夹中使用 ffmpeg)

进程之间的对话:

    // message directors for threading
    private BlockingCollection<string> commandsForParser = new BlockingCollection<string>();
    private BlockingCollection<string> commandsForMain = new BlockingCollection<string>();

    // sending commands to threads
    public void SendCommmandParser(string command)
    {
        commandsForParser.Add(command);
        //Debug.WriteLine("P: " + command);
    }
    public void SendCommmandMain(string command)
    {
        commandsForMain.Add(command);
        //Debug.WriteLine("M: " + command);
    }

解析调用:

    private void showParsedConsole()
    {
        ConsoleOutput dlg = new ConsoleOutput();
        dlg.Show();

        //...

        while (true)
        {
            System.Windows.Forms.Application.DoEvents();

            string command = commandsForParser.Take();
            
            // if null, ffmpeg finished
            if (command == null || command == "..break..")
                    {
                        SendCommmandMain("..break..");
                        dlg.Close();
                        break;
                    }

            if (dlg.toClose)
            {
                SendCommmandMain("..cancel..");
                dlg.Close();
                break;
            }
            else if (command != null)
            {
                //... actualizing form (output, progress things)
            }
            else
                dlg.addMessage("\n");
        }
    }

开始转换:

    public string RunExternalExe(string info, string filename, string arguments = null)
    {
        // parse console in new thread
        var thread = new Thread(showParsedConsole);
        thread.Start();

        //...

        #region init process to run
            var process = new Process();

            process.StartInfo.FileName = filename;
            if (!string.IsNullOrEmpty(arguments))
            {
                process.StartInfo.Arguments = arguments;
            }

            process.StartInfo.CreateNoWindow = true;
            process.StartInfo.WindowStyle = ProcessWindowStyle.Minimized;
            process.StartInfo.UseShellExecute = false;

            process.StartInfo.RedirectStandardError = true;
            process.StartInfo.RedirectStandardOutput = true;

            var stdOutput = new StringBuilder();
            var errOutput = new StringBuilder();
        #endregion

        #region redirect stdOut/stdError
            process.OutputDataReceived += (sender, args) =>
            {
                SendCommmandParser(args.Data);
                stdOutput.Append(args.Data + "\n");
                Debug.WriteLine("S: " + args.Data);
            };
                            
            process.ErrorDataReceived += (sender, args) =>
            {
                SendCommmandParser(args.Data);
                errOutput.Append(args.Data + "\n");
                // if the form is freezing, the debugger will still output these
                Debug.WriteLine("E: " + args.Data);
            };
        #endregion

        #region run process
            try
            {
                process.Start();
                process.BeginOutputReadLine();
                process.BeginErrorReadLine();

                while (!process.HasExited)
                {
                    System.Windows.Forms.Application.DoEvents();

                    string command = commandsForMain.Take();

                    if (command == "..cancel..")
                    {
                        Debug.WriteLine("============== 1");
                        process.Kill();

                        while (process != null && !process.HasExited)
                        {
                            //wait
                        }
                        // return if canceled to provide excetion (process == null)
                        return "C";
                    }

                    if (command == "..break..")
                    {
                        Debug.WriteLine("============== 2");
                        process.WaitForExit();
                        break;
                    }
                    /*...*/
                }

                Debug.WriteLine("============== 3");
                SendCommmandParser("..break..");
            }
            catch
            {
            }
        #endregion
            Debug.WriteLine("============== 4");
    

       //... handling OK, CANCEL, ERROR
    }

任何人都可以找到导致冻结的结构性问题吗?(实际上我运行 2 次转换没有任何错误,但没有更改代码)

谢谢你的帮助。

~ADD~ 现在我得到了一个冻结运行,调试器没有输出"============== #",所以解析线程确实冻结了......但是为什么呢?

4

1 回答 1

0

多亏了马修,看起来确实Application.DoEvents()提高了冻结。我不知道为什么,但我完全重组了代码,所以主 gui 将转换请求发送到 a BlockingCollection<>,这将由一个新线程处理。

为了保持窗口不冻结,我使用 main-gui-thread 对其进行了初始化,并使用Invokes 从工作线程对其进行了更新。

重组另一个项目是一项艰巨的工作,因为主要形式是调用不同的转换及其成功条件,但实际上它是有效的。

对于未来,我知道:只需调用一个类即可调用密集型工作,以使以后的并行化更容易;)

于 2013-05-17T19:20:21.850 回答