Запуск двух потоков запускает их последовательно и не в одно и то же время

Question

У меня есть основной поток, который управляет формой окна, при нажатии кнопки выполняются два потока. Один используется для записи информации, другой используется для его чтения. Идея положить их в потоки - это позволить пользователю взаимодействовать с интерфейсом во время выполнения.

Вот создание двух потоков;

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

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

В данные просто данных объект, который хранит данные, записанные во время записи.

Проблема, с которой я столкнулась, заключается в том, что первый поток выполняется отлично, второй отказывается работать до тех пор, пока первый не завершится. Помещение контрольной точки во вторую функцию потоков, ReadData позволяет мне знать, что она вызывается только после того, как первый поток выполняется со всей его записью.

Я пытался решить это в течение нескольких часов, и я не могу понять, почему он это сделает. Добавление a;

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

данные объект имеет замок в обеих функций, которые призваны; ReadLastData и Read.

Вот методы в Данные объект.

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? Возможно, это просто ваша операционная система Windows (mono cpu ??), которая не позволяет второму потоку получить доступ к ресурсам процессора.

Не делайте этого: замок (это)

ли что-нибудь подобное вместо:

private object oLock = new object(); 

[...] 

lock (this.oLock) 

EDIT: Не могли бы вы попробовать звонки, как это:

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