Поток переходит в состояние ожидания или сна при попытке добавить строки в Datatable

Question

Я создал поток, который вызывает веб-сервер - читает некоторые данные - записывает строки в таблицу DataTable

Мой текущий поток, который - ожидает поступления новых строк - передает данные в систему

Проблема в том, что мой поток записи переходит в режим Wait-Sleep-Join (это стало известно из окна инструмента потока), когда он пытается записать строки в Datatable

Структура кода выглядит примерно так:

class DataRetriever
{
    Thread GetReport;

    private DataTable ServerData;

    int rowCount = 0;

    private int _lastReadedRowNo = -1;

    public GetData()
    {
        thrGetReport = new Thread(new ThreadStart(fn_thrGetReport));
                thrGetReport.Name = "CallServer";
                thrGetReport.IsBackground = true;
                thrGetReport.Start();
    }

    //Writer Thread Executes this
    private void fn_thrGetReport()
        {
            for (int i = 0; i < cnt; i++)
            {
                DataRowCollection drcTemp = server.GetAnswer(parameter);

                for (int j = 0; j < drcTemp.Count; j++)
                {                    
                    ServerData.Rows.Add(drcTemp[j].ItemArray); // Here thread goes in Sleep/wait Mode
                    Interlocked.Increment(ref rowCount);
                }
            }

        }

    //This executes in Current Thread
     public bool Read
        {
            get
            {        
                if (no more data to ask condition)
                {
                    return false;
                }
                else
                {
                    //wait till new rows are not entered                                      
                     while (rowCount <= (_lastReadRowNo + 1) ) //Writer thread is in sleep/wait mode so this piece of code executes infinetly
                     ;                    


                    while (Condition Here)
                    {
                        // Read Datarows here 
                //Copy the Read rows to some _toReturndt
                        i++;
                    }

                    _lastReadRowNo = i - 1;
                    return true;
                }
            }
        }


        public DataRowCollection GetNextData()
        {
           DataTable temp = _toReturnDt;
            _toReturnDt.Rows.Clear();
            return temp.Rows;
        }
}


public class DataProcessor
{

    public GetnProcess()
    {
        DataRetriever DataRetriever1 = new DataRetriever();
        DataRetriever1.GetData();

        while (this.DataRetriever1.Read)
        {
            DataRowCollection drc = this.DataRetriever1.GetNextData();
        }
    }
}

Answer 1

Проблема в том, что если вы добавите строку в DataTable, DataTable вызовет событие. К событиям подключены элементы управления пользовательского интерфейса из wiforms / wpf. Элементы управления «хотят что-то сделать» после возникновения события, но текущий поток является не потоком пользовательского интерфейса, а рабочим потоком. Это суть проблемы.

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

DataRetriever.LoadDataFromServer( this.gridView1, this.myDataTable );
// ... elsewhere ...
public class DataRetriever {
    // uiSynchronizer can run delegates in UI thread
    // uiSynchronizer can be instance of "System.Windows.Forms.Control" (or derived) class
    public void LoadDataFromServer( ISynchronizeInvoke uiSynchronizer, DataTable target ) {
        // QueueUserWorkItem runs delegate in separated thread
        ThreadPool.QueueUserWorkItem((_state)=>{
            // getting rows from server
            var serverRows = server.GetAnswer(parameter);

            // addRows delegate must be called on UI thread
            Action addRows = ()=> {
                try {
                    target.BeginLoadData();
                    foreach(DataRow in serverRow in serverRows) {
                        target.Rows.Add( serverRow.ItemArray );
                    }
                }
                finally {
                    target.EndLoadData();
                }
            };

            // uiSynchronizer.Invoke runs "addRows" delegate on UI thread
            uiSynchronizer.Invoke(addRows);
        });
    }
}

EDIT:

Хорошая статья о многопоточности в Winforms находится на CodeProject: Что случилось с BeginInvoke?