День добрый, есть такая задача. Я запускаю один поток, который заполняет некий список. Также я запускаю несколько потоков (функция-обработчик у них одна), которые из этого списка значения тягают. Самой простой вариант этих двух функций выглядит как-то так
| Код |
void CThreadsDlg::AddToList(void)
{
CString valueStr;
static int value = 0;
while(true)
{
if(m_listValues.GetItemCount() <= 25)
{
valueStr.Format("%d", value++);
{
lock_guard<mutex> guard(m_list1Mutex);
m_listValues.InsertItem(0, valueStr);
}
}
Sleep(100);
}
}
// тут берется значение из одного списка и вставляется в другой
void CThreadsDlg::GetFromToList(void)
{
CString valueStr;
while(m_stopAll == false)
{
{
{
lock_guard<mutex> guard(m_list1Mutex);
if(m_listValues.GetItemCount() > 0)
{
valueStr = m_listValues.GetItemText(m_listValues.GetItemCount() - 1, 0);
m_listValues.DeleteItem(m_listValues.GetItemCount() - 1);
m_resultList.InsertItem(0, valueStr);
}
}
}
Sleep(300);
}
}
|
Но, как я понимаю, тут есть проблема (может и не одна), которая заключается в том, что потоки, которые "обрабатывают" значения из главного списка, работают постоянно. То есть бесконечный цикл, постоянно проверяет кол-во элементов на > 0. А ведь это процессорное время и т.п. Тогда я подумал сделать какое-нибудь событие. Типа поток, который AddToList, добавляет в список элемент и сигнализирует, "мол в списке что-то появилось, давайте, обрабатывайте". Но тогда в каком месте нужно ставить событие в состояние "список пуст, больше брать нельзя". Что мне приходит на ум:
1. добавить это в функцию GetFromToList, но ведь это просто обработчик, зачем ему проверять пуст ли список и создавать какое-то событие, к тому же его тоже нужно блокировать мьютексом, что не было одновременно можно-нельзя.
2. можно завести еще один поток, который бы синхронизировал этот момент. Но это тоже какой-то огород получается.
3. может есть другое решение?
Спасибо. |
)
