在动态创建的多线程中维持参数值？ (C#)

Question

我不能说我完全理解线程的概念，即使我读了很多关于它的文章，我有点厚，我想要的是线程安全参数。我正在将字符串参数发送到一个线程，我正在使用 ThreadPool.QueueUserWorkItem 启动该线程，但我在它之后再次使用同一个线程和另一个参数。

我希望它能够处理具有不同参数的不同线程，但它不稳定，可能是因为我在调用第一个线程后立即更改参数字符串。我的直觉告诉我使用 Lock，但不知道如何使用以及在哪里使用。

哦，顺便说一句，这段代码的输出通常是 3 个使用最新参数的线程（这是 200p 的配置），

我用来调用我的线程的代码是这;

    processThread pt = new processThread();
    pt.fileName = AppDomain.CurrentDomain.BaseDirectory + "bin\\ffmpeg.exe";
    pt.filePath = Path.Combine(Vci.Core.Sandbox.UploaderControlSandboxPath, fileGuid);
    pt.vidPathHigh = AppDomain.CurrentDomain.BaseDirectory + "videos\\480p\\" + fileGuid + ".wmv";
    pt.vidPathMid = AppDomain.CurrentDomain.BaseDirectory + "videos\\360p\\" + fileGuid + ".wmv";
    pt.vidPathLow = AppDomain.CurrentDomain.BaseDirectory + "videos\\200p\\" + fileGuid + ".wmv";
    if (height >= 480) 
    {
        newHeight = (int)Math.Floor(480 * aspectRatio);
        initArgs = "-i " + pt.filePath + " -vcodec wmv2 -qscale 2 -s " + newHeight + "x480 -acodec wmav2 -ar 44100 -ab 128k -y \"" + pt.vidPathHigh + "\"";
        ThreadPool.QueueUserWorkItem(o => pt.callExecute(initArgs));
        newHeight = (int)Math.Floor(360 * aspectRatio);
        initArgs = "-i " + pt.filePath + " -vcodec wmv2 -qscale 4 -s " + newHeight + "x360 -acodec wmav2 -ar 44100 -ab 128k -y \"" + pt.vidPathMid + "\"";
        ThreadPool.QueueUserWorkItem(o => pt.callExecute(initArgs));
        newHeight = (int)Math.Floor(200 * aspectRatio);
        initArgs = "-i " + pt.filePath + " -vcodec wmv2 -qscale 6 -s " + newHeight + "x200 -acodec wmav2 -ar 44100 -ab 128k -y \"" + pt.vidPathLow + "\"";
    }

我的线程类的代码是这样的；

    public class processThread
    {
    public string filePath { get; set; }
    public string fileName { get; set; }
    public string vidPathHigh { get; set; }
    public string vidPathMid { get; set; }
    public string vidPathLow { get; set; }
    public void callExecute(Object o)
    {
        try
        {
            executeProcess(fileName, o as string);
        }
        catch (ThreadAbortException abortException)
        {
            // do something
        }
    }

    private void executeProcess(string fileName, string arguments)
    {
        Process myProcess = new Process();
        myProcess.StartInfo.FileName = fileName;
        myProcess.StartInfo.Arguments = arguments;
        myProcess.StartInfo.UseShellExecute = false;
        myProcess.StartInfo.CreateNoWindow = false;
        myProcess.StartInfo.RedirectStandardOutput = false;
        try
        {
            myProcess.Start();
        }
        catch (Exception ex)
        {
            throw;
        }
        myProcess.WaitForExit();
        myProcess.Close();
    }
}

预先感谢任何帮助！

Answer 1

问题是您正在通过使用 lambda 表达式“捕获”initargs。

您不应该以这种方式重用 initargs。您的代码将更具可读性且更易于维护，并且您将避免此问题。

因此，首先，使用两个不同的 initargs 实例：

string initArgsWithScaleTwo = // 
ThreadPool.QueueUserWorkItem(o => pt.callExecute(initArgsWithScaleTwo));
string initArgsWithScaleFour = //
ThreadPool.QueueUserWorkItem(o => pt.callExecute(initArgsWithScaleFour));    

其次，当您分配给 initArgs 时，会出现大量不必要的重复。维护起来并不有趣。这应该让您开始使用更清晰的版本：

private string GetInitArgs(
    string filePath,
    int scale,
    int newHeight,
    string vidPathHigh,
    int scanLines
) {
    return "-i " + filePath + String.Format(" -vcodec wmv2 -qscale {0} -s ", scale) + newHeight + String.Format("x{0} -acodec wmav2 -ar 44100 -ab 128k -y \"" + pt.vidPathHigh + "\"", scanLines);
}

您可以做更多事情并使用 String.Format 来真正清理整个事情。

那么你可以说，

string initArgsWithScaleTwoAnd480ScanLines = 
    GetInitArgs(
       pt.filePath,
       2,
       (int)Math.Floor(480 * aspectRatio,
       pt.vidPathHigh,
       480
    );

综上所述，如果线程只是启动新进程，我根本不明白你为什么要使用线程。只需直接启动进程，然后等待它们全部完成即可。

Answer 2

嗯，我不确定我是否明白你在问什么。 Process.Start 通常不会阻塞当前线程，因此您可以启动尽可能多的新进程，因为您的系统可以从应用程序的单个线程中吞下...

Answer 3

我不确定 initArgs 的定义位置，因此更改它并调用使用它的线程可能会导致一些问题。

但我建议您查看 Joseph Albahari 关于线程的免费电子书。这是一个很好的资源，并提供了一些关于如何为各种线程场景设计代码的好建议。对于您的情况，您可能需要考虑等待和脉冲模式。