.net - 将任务并行库 (C# .NET 4.0) 与外部 exe (ffmpeg) 一起使用而不会发生冲突

Question

几天来我一直在尝试解决一个问题。我是多线程的初学者。我的目标是使用 ffmpeg.exe 同时运行多个视频编码任务，并使用服务器的所有功能。

我有一个 C# 包装器，它启动 ffmpeg.exe 进程并在没有线程的情况下工作(或仅使用 ffmpeg 内部线程(不适用于 flv 编码))，它看起来像这样:

using (Process process = new Process())
{
    process.StartInfo.FileName = encoderPath + "ffmpeg.exe";

    process.StartInfo.UseShellExecute = false;
    process.StartInfo.RedirectStandardOutput = true;
    process.StartInfo.RedirectStandardError = true;
    process.StartInfo.CreateNoWindow = false;

    string arguments = "-y -i " + filenameInput + " -f " + 
        GetVideoFormatName(format) + " -vcodec " + GetVideoCodecName(codec);

    // (most argument setup has been omitted for brevity)
    arguments += " " + filenameOutput + " ";

    process.StartInfo.Arguments = arguments;
    process.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
    process.Start();

    bool succes = LireSortie(process);
    process.WaitForExit();
    process.Close();
    return succes;
}

下面的代码调用包装器。每个 Encode 方法的第二个参数是用于内部 ffmpeg 线程的线程数。当我禁用它时，它不起作用。

var fm = new FFMpegWrapper();

fm.FilenameInput = "test.mp4";
//VideoInfo videoinfo = fm.GetVideoInfo();
Task[] tasks = {
    Task.Factory.StartNew(
        new Action(()=>{ fm.Encodeto200p("test200p.mp4", 4); })),
    Task.Factory.StartNew(
        new Action(()=>{ fm.EncodetoFlash200p("test200p.flv"); })),
    // ... (calls to other Encode methods ommitted) ...
    Task.Factory.StartNew(
        new Action(()=>{ fm.Encodeto404p("test404p.mp4", 4); })),
    Task.Factory.StartNew(
        new Action(()=>{ fm.EncodetoFlash404p("test404p.flv"); })),
    Task.Factory.StartNew(
        new Action(()=>{ fm.Encodeto720p("test720p.mp4", 4); }))
};

Task.WaitAll(tasks, 5000);

您可能想知道为什么我将 WaitAll() 的超时设置为 5000。这是因为调用线程无限期地等待，因为 TPL 没有检测到任务的结束。 ffmpeg.exe 进程在编码中间“停止”，并以 0% 的 CPU 继续运行。

我认为 TPL 和 Process 是冲突的。当我使用 TPL 获取每个任务的状态时，它始终保持“正在运行”。我想使用 TPL(或其他一些机制)捕获 ffmpeg 进程的真实事件，因为我想防止应用程序崩溃并想管理成功和失败。

Answer 1

我怀疑问题出在 TPL 或任何用于检测进程是否结束的本地机制。我怀疑真正的原因是等待不是无限期的，而是由于对特定资源的压力而导致的典型情况。

鉴于您对正在发生的事情的描述，并且 CPU 似乎处于低水平，您的压力可能在 IO 或内存上。我建议至少使用性能计数器(并使用任务管理器来快速查看表面级别)来分析您的应用程序，以找出正在发生的事情。

正如一位评论者所建议的，消除任务分配并确定一次、两次或更多次编码串行调用是否至少有效是有意义的。可能是一个特定的调用阻碍了一切(例如编码错误)，而不是资源问题。