Имеется такой код.
// Коллекция буферов на запись
List<List<int>> writeReadyList = new List<List<int>>();
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
// Локальный буфер данного потока
List<int> localBufer = new List<int>();
Random random = new Random();
while (!backgroundWorker1.CancellationPending)
{
// Забиваем локальный буфер значениями
localBufer.Add(random.Next(0, 100));
if (localBufer.Count > 10)
{
// Передаем буфер в очередь на запись и обнуляем его
writeReadyList.Add(localBufer);
localBufer = new List<int>();
}
Thread.Sleep(50);
}
}
private void backgroundWorker2_DoWork(object sender, DoWorkEventArgs e)
{
while (!backgroundWorker2.CancellationPending)
{
// Коллекция буферов, которые не удалось записать
List<List<int>> failList = new List<List<int>>();
foreach (List<int> currentBufer in writeReadyList)
{
try
{
// Пишем значения из перебираемого буфера в базу данных
}
catch { failList.Add(currentBufer); }
}
writeReadyList = new List<List<int>>(failList);
Thread.Sleep(450);
}
}
Немного пояснений по коду - первый поток читает некие значения, копит их в локальном буфере. При достижении определенного количества элементов локальный буфер ставится в очередь на запись и сбрасывается. Второй поток смотрит, что у нас есть в очереди на запись и, собственно, пишет значения в базу данных. Изменять коллекцию в foreach нельзя, поэтому, чтобы исключить все, что записалось успешно, формирую список из неудачно записанных буферов.
Насколько понимаю, при таком подходе возможны несколько вариантов некорректной работы.
в момент работы foreach во втором потоке она будет изменена из первого потока - получаем исключение?
второй поток выполнил перебор очереди, но еще не выполнил перезаписи в соответствии с неудавшимися попытками записи. В этот момент первый добавляет запись, но, так как второй ничего об этом не знает, то запись будет потеряна.
Как правильно организовать работу с очередью на запись между этими потоками? Причем организовать надо так, чтобы если второй поток в данный момент обрабатывает очередь, то первый поток не ждал окончания работы с ресурсом, а продолжал складывать значения в свой локальный буфер. В какую сторону копать?
______UPD:
По совету VladD использовал мьютексы.
Mutex writeReadyAccess = new Mutex();
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
if (localBufer.Count > 10)
// Таймаут в 1 секунду тк нельзя тормозить первый поток на время обработки очереди
if (writeReadyAccess.WaitOne(1))
{
// Если второй поток не обрабатывает очередь, то добавляем в нее локальный буфер и обнуляем его
writeReadyAccess.ReleaseMutex();
}
// Если очередь была в обработке на момент запроса, то продолжаем писать в локальный буфер
}
private void backgroundWorker2_DoWork(object sender, DoWorkEventArgs e)
{
// Этот поток можно тормозить по времени, поэтому ждем без таймаута
if (writeReadyAccess.WaitOne())
{
// Обработка очереди, в том числе ее перезапись
writeReadyAccess.ReleaseMutex();
}
}