Мне нужно чтобы поток выделял память, сохранял в vector, а потом завершался, и при этом к vector имеют доступ основной поток, поэтому ещё и синхронизация нужна.
Вроде всё делаю правильно, но почему-то происходит ошибка доступа к памяти (как я понял): Unhandled exception in Test.exe: 0xC0000005: Access Violation.

Вот мой код с ошибкой, можно сразу создать новое win32 application, и запустить.
Здесь 10 потоков CAfcTest выделяют память и сохраняют в vector, а в деструкторе память освобождается. В общем, помогите плиз найти ошибку или другое решение

Код

class CAfcTest { public: HANDLE m_hThread; CRITICAL_SECTION m_Crit; BOOL m_bRun; std::vector<DWORD*> m_vec; public: CAfcTest(); virtual ~CAfcTest(); BOOL WorkProc(); BOOL Create(); VOID Destroy(); BOOL IsActive() const; }; #define MYTHREAD_COUNT 10 int APIENTRY WinMain(HINSTANCE hInstance,                     HINSTANCE hPrevInstance,                     LPSTR     lpCmdLine,                     int       nCmdShow) {  {  CAfcTest test[MYTHREAD_COUNT];  INT   i;  for (i = 0; i < MYTHREAD_COUNT; i++)   test[i].Create();  for (i = 0; i < 5; i++)   Sleep(1000);  for (i = 0; i < MYTHREAD_COUNT; i++)   test[i].Destroy(); } ::MessageBox(NULL, "complite", "test", MB_OK); return 0; } inline CAfcTest::CAfcTest() { ::InitializeCriticalSection(&m_Crit); } inline CAfcTest::~CAfcTest() { std::vector<DWORD*>::const_iterator  iter, iterEnd; DWORD *pData; ::EnterCriticalSection (&m_Crit); iter = m_vec.begin(); iterEnd = m_vec.end(); while (iter != iterEnd) {  pData = (*iter);  if (pData)   delete pData;  iter++; } m_vec.clear(); ::LeaveCriticalSection (&m_Crit); ::DeleteCriticalSection(&m_Crit); } inline DWORD WINAPI fnTestProc(VOID* lpParameter) { CAfcTest* pThread = (CAfcTest*)lpParameter; do { } while (pThread->WorkProc()); CloseHandle(pThread->m_hThread); pThread->m_hThread = NULL; return 0; } inline BOOL CAfcTest::Create() { DWORD dwThreadId; m_bRun = TRUE; return ((m_hThread = CreateThread(NULL, 0, fnTestProc, (VOID*)this, 0, &dwThreadId)) != NULL); } inline VOID CAfcTest::Destroy() { if (!IsActive())  return; ::EnterCriticalSection (&m_Crit); m_bRun = FALSE; ::LeaveCriticalSection (&m_Crit); if (WaitForSingleObject(m_hThread, 1000) != WAIT_OBJECT_0) {  ::TerminateThread(m_hThread, 1);  CloseHandle(m_hThread);  m_hThread = NULL; } } inline BOOL CAfcTest::WorkProc() { ::EnterCriticalSection (&m_Crit); DWORD *pData = new DWORD; m_vec.push_back(pData); ::LeaveCriticalSection (&m_Crit); return m_bRun; } inline BOOL CAfcTest::IsActive() const { DWORD dwExitCode; return (m_hThread && ::GetExitCodeThread(m_hThread, &dwExitCode) && (dwExitCode == STILL_ACTIVE)); }

Цитата(Allest @ 27.8.2004, 00:38)

do { } while (pThread->WorkProc());

У тебя функция WorkProc() выполняется хрен знает сколько раз. Ошибка происходит, когда на миллион-какой-то итерации происходит переполнение памяти. А ты чего ожидал? Память-то не резиновая.

В смысле в фунции много памяти выделяется из-за этого

Код

DWORD *pData = new DWORD;

?
А если сразу освобождать, то всё равно ошибка, т.е. если передалать так

Код

BOOL CAfcTest::WorkProc() { ::EnterCriticalSection (&m_Crit); DWORD *pData = new DWORD; if (pData)  delete pData;// сразу освобождаю ::LeaveCriticalSection (&m_Crit); return m_bRun; }

Цитата(Allest @ 28.8.2004, 00:59)

В смысле в фунции много памяти выделяется из-за этогоКод  DWORD *pData = new DWORD;  ?

В смысле да. Ты нафига постоянно-то это вызываешь? Если не можешь понять что ты делаешь - вот полный аналог твоей программы

Код

void main { for(;;) {DWORD *ptr=new DWORD;} }

Посмотри как это будет работать.
Тебе вообще, что надо сделать? Расскажи задачу поподробнее.

Спасибо за желание помочь. Думаю я понял почему появлялась ошибка: я вызывал 10 thread и каждый асихронно вызывал new и delete, из-за этого иногда 2 потока захватывали один и тот же блок памяти, а потом один из них освобождает эту память, а у другого остаётся указатель в "никуда" и при его вызове delete возникает та самая ошибка.
Или я ошибаюсь? Ведь нединамические переменные тоже память берут, но с ними проблем не было в отличае от созданных с помощью new.

Код

VOID WorkProc() { INT arrStaticMemory[1000];// вот эта память как-то выделяется и освобождается и никому не мешает }

А задача была у меня создать файловую панель типа как в TotalCommander, но проще: список файлов в ListView, и icons, ассоциируемые с файлами должны были загружаться в thread. Для этого после построения списка файлов запускал thread, который извлекал icons и добавлял HICON в vector и постил сообщение окну списка, чтобы тот прикрутил себе извлечённые icons.
Как это сделать?

Цитата(Allest @ 29.8.2004, 23:27)

Думаю я понял почему появлялась ошибка: я вызывал 10 thread и каждый асихронно вызывал new и delete,

Думаю, ты нифига не понял. Потоки у тебя синхронизируются совершенно нормально - нафига, иначе, критические секции существуют. А ошибка у тебя вылезает именно из-за переполнения памяти - покажи, где ты это контролируешь, если не согласен. Я поставил вот так и посмотрел сколько раз у тебя вызывается new

Код

static int n=0; BOOL CAfcTest::WorkProc() { ::EnterCriticalSection (&m_Crit); DWORD *pData = new DWORD; m_vec.push_back(pData); ++n; ::LeaveCriticalSection (&m_Crit); return m_bRun; }

получилось дохрена. И исключение срабатывает, похоже в m_vec.push_back(pData) - массивы тожке не резиновые.
А вообще зачем ты хранишь указатели на DWORD? Храни тогда уж просто значение std::vector<DWORD> m_vec.

Цитата(Allest @ 29.8.2004, 23:27)

А задача была у меня создать файловую панель типа как в TotalCommander, но проще: список файлов в ListView, и icons, ассоциируемые с файлами должны были загружаться в thread. Для этого после построения списка файлов запускал thread, который извлекал icons и добавлял HICON в vector и постил сообщение окну списка, чтобы тот прикрутил себе извлечённые icons. Как это сделать?

Во первых потоки делай с приоритетом ниже нормального - иначе они нет смысла - они забьют основной поток. В вторых так и делай - загружай иконки в массив, синхронизируй с помощью критических секций, и чер определённое время, например на каждые 10 иконок посылай сообщени - SendMessage. В функции потока контролируй какую-нибудь булевскую переменную - завершение потока. Типа того

Код

while (bContinue) { ///Функция загрузки ::WaitForSingleObject(ev,INFINITE);// Ожидаем следующей команды загрузки } return;

ev - событие с ручным сбросом - чтобы поток останавливался, когда ничего загружать не надо. Когда завершаешь поток делай

Код

bContinue=false; SetEvent(ev); WaitForSinlgeObject(hTread,INFINITE)

TerminateThread делать не надо

Цитата

А ошибка у тебя вылезает именно из-за переполнения памяти - покажи, где ты это контролируешь, если не согласен.

Не из-за переполнения памяти, повторяю

Цитата

А если сразу освобождать, то всё равно ошибка, т.е. если передалать так BOOL CAfcTest::WorkProc() { ::EnterCriticalSection (&m_Crit); DWORD *pData = new DWORD; if (pData) delete pData;// сразу освобождаю ::LeaveCriticalSection (&m_Crit); return m_bRun; }

Цитата

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

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

Цитата

И исключение срабатывает, похоже в m_vec.push_back(pData)

Кстати, а как его перехватить?
А за советы спасибо.

Цитата(Allest @ 30.8.2004, 13:36)

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

Точно, а я и не обратил внимания. Переделал уже?

Цитата(Allest @ 30.8.2004, 13:36)

Кстати, а как его перехватить?

Из МСДН:

Код

try   {      vector<int, stingyallocator< int > > myv;      for ( int i = 0; i < 11; i++ ) myv.push_back( i );   }   catch ( exception &e )   {      cerr << "Caught " << e.what( ) << endl;      cerr << "Type " << typeid( e ).name( ) << endl;   };