启动两个线程按顺序而不是同时运行它们

Question

我有一个控制窗体的主线程，在按下按钮时会执行两个线程。一个用于记录信息，另一个用于读取信息。将这些放入线程背后的想法是让用户能够在执行时与界面进行交互。

这里是两个线程的创建；

Thread recordThread = new Thread(() => RecordData(data));
recordThread.Name = "record";
recordThread.Start();

Thread readThread = new Thread(() => ReadData(data));
readThread.Name = "read";
readThread.Start();

data 只是一个数据对象，用于存储在录制过程中记录的数据。

我面临的问题是第一个线程执行得很好，第二个拒绝运行，直到第一个完成。在第二个线程函数中放置一个断点，ReadData 让我知道只有在第一个线程完成所有记录后才会调用它。

我已经尝试解决这个问题几个小时了，但我无法理解它为什么会这样做。添加一个;

while(readThread.IsAlive) { }

在开始之后将停止执行之后的任何内容，并且它的状态是正在运行。但它不会转到给定的方法。

有什么想法吗？

编辑： 线程调用的两个函数是；

    private void RecordData(Data d)
    {
        int i = 0;
        while (i < time * freq)
        {
            double[] data = daq.Read();
            d.AddData(data);
            i++;
        }
    }

    private void ReadData(Data d)
    {
        UpdateLabelDelegate updateData =
            new UpdateLabelDelegate(UpdateLabel);

        int i = 0;
        while (i < time * freq)
        {
            double[] data = d.ReadLastData();
            this.Invoke(updateData, new object[] { data });
            i++;
        }
    }

data 对象在调用的两个函数中都有锁定； ReadLastData 和读取。

这里是 Data 对象中的方法。

    public void AddData(double[] data)
    {
        lock (this)
        {
            int i = 0;
            foreach (double d in data)
            {
                movementData[i].Add(d);
                i++;
            }
        }
    }

    public double[] ReadLastData()
    {
        double[] data = new double[channels];
        lock (this)
        {
            int i = 0;
            foreach (List<double> list in movementData)
            {
                data[i] = list[list.Count - 1];
            }
        }
        return data;
    }

Answer 1

看起来您的阅读/写作之间存在竞争条件。在您的第一个线程中，您在向对象添加数据的同时锁定对象，而在第二个线程中，您尝试 获得对它的排他锁以开始读取。但是，问题是第一个线程执行得如此之快，以至于第二个线程永远没有机会获得锁。

这个问题的解决方案真的取决于你在这里追求什么样的行为。如果您希望在每次写入后获得连续读取，那么您需要做的是控制读取/写入操作之间的执行，例如

static AutoResetEvent canWrite = new AutoResetEvent(true); // default to true so the first write happens
static AutoResetEvent canRead = new AutoResetEvent(false);
...
private void RecordData(Data d)
{
    int i = 0;
    while (i < time * freq)
    {
        double[] data = daq.Read();
        canWrite.WaitOne(); // wait for the second thread to finish reading
        d.AddData(data);
        canRead.Set(); // let the second thread know we have finished writing
        i++;
    }
}

private void ReadData(Data d)
{
    UpdateLabelDelegate updateData =
        new UpdateLabelDelegate(UpdateLabel);

    int i = 0;
    while (i < time * freq)
    {
        canRead.WaitOne(); // wait for the first thread to finish writing
        double[] data = d.ReadLastData();
        canWrite.Set(); // let the first thread know we have finished reading
        this.Invoke(updateData, new object[] { data });
        i++;
    }
}

Answer 2

您可以尝试在 RecordData 中添加睡眠吗？ 也许只是您的（单核 CPU ？？）Windows 操作系统不允许第二个线程获得 CPU 资源。

不要这样做： 锁（这个）

改为这样做：

private object oLock = new object();

[...]

lock (this.oLock)

编辑： 你能试试这样的电话吗：

Thread recordThread = new Thread((o) => RecordData((Data)o));
recordThread.Name = "record";
recordThread.Start(data);