Форум программистов, компьютерный форум CyberForum.ru

С++ для начинающих

Войти
Регистрация
Восстановить пароль
 
Рейтинг: Рейтинг темы: голосов - 12, средняя оценка - 4.83
daarg
0 / 0 / 1
Регистрация: 05.11.2008
Сообщений: 164
#1

WaitForSingleObject и многопоточность - C++

05.10.2010, 18:18. Просмотров 1409. Ответов 1
Метки нет (Все метки)

Добрый день! Мучаюсь с такой задачкой. Имеется C++ DLL, которую до меня писал другой программист. Одна из ее функций хватает(считывает, граббит) HTML-код с сайта, имя которого задается. Эта функция использует многопоточность. Причем каждый поток - это страничка с сайта. Вот код -
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
int CScanner::ProcessGrabbing()
{
    //start grabbing site
    WriteLog('Start grabbing: '+csStartURL); - write to Log file
    clURLQueue.AddTail(csStartURL.MakeLower()); //1-st URL to process
    if(ClearDir(csTempDir))
        return 1; //error clear directory
    
    //start 1-st thread
    ceProcessedAll.ResetEvent();
    int iThreadNum=0;
    ceProcessed.ResetEvent();
    AfxBeginThread(*ProcessLinkThread, &iThreadNum,THREAD_PRIORITY_LOWEST);
    WaitForSingleObject(ceProcessed,INFINITE);
    //start other threads
    while(true)
    {
        ccsLock.Lock();
        if(lCurrentRun<m_iThreads && clURLQueue.GetCount()>0)
        {
            InterlockedIncrement((LPLONG)&lOutputIndex);
            iThreadNum=lOutputIndex;
            ccsLock.Unlock();
            AfxBeginThread(*ProcessLinkThread, &iThreadNum,THREAD_PRIORITY_LOWEST);
            WaitForSingleObject(ceProcessed,INFINITE);
        }
        else
        {
            ccsLock.Unlock();
            Sleep(1);
        }
        ccsLock.Lock();
        if(clURLQueue.GetCount()==0 && lCurrentRun==0)
        {
            ccsLock.Unlock();
            break;
        }
        ccsLock.Unlock();
    }
    WriteLog('!!before WaitForSignalObject!');
    WaitForSingleObject(ceProcessedAll,INFINITE);
    WriteLog('!!Process Grabbing end!');
    return 0;
}
Где ProcessLinkThread - потоковая функция
Так вот - все сайты сканируются нормально, а на одном определенном сканирование останавливается перед самым концом. Видимо есть какие-то ресурсы, которые держат поток (потоки), и благодаря WaitForSingleObject - процесс в целом повисает.
Помогите разобраться, в чем тут может быть дело?
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
05.10.2010, 18:18     WaitForSingleObject и многопоточность
Посмотрите здесь:

WaitForSingleObject - C++
Приветствую. Вот собственно код который нужно поправить. void changeFile() { DWORD dwWaitStatus; HANDLE dwChangeHandles; ...

Потоки. WaitForSingleObject. - C++
Здравствуйте! Помогите пожалуйста решить проблему. Читать лучше сразу самый низ кода - большой комент, там в принципе вся проблема и...

Приложение останавливается на WaitForSingleObject - C++
Виснет приложение через не определенное время после старта, стек вызов показывает что программа останавливается на функции...

WaitForSingleObject вешает интерфейс - C++
Вот решил написать функцию для запуска процесса и ожидание завершения. void StartAndWait (char* Program, char* WorkDirectory) { ...

Многопоточность - C++
Всем привет, заметил в одном проекте подобный код: struct Counter { int i; } #define g_counter ACE_Singleton&lt; Counter,...

Многопоточность - C++
Здравствуйте уважаемые форумчане! Суть проблемы такова, в нижней задаче есть две методы сортировки, и эти два метода надо чтобы выполнялись...

Многопоточность - C++
Здраствуйте! Объясните пожалуйста понятными словами что такое многопоточность и для чего она нужна?

Многопоточность - C++
При добавлении больше 10000 элементов в таблицу на форму форма зависает, как это исправить? (использую QT)

Многопоточность - C++
Есть задание: Написать и протестировать функцию, которая находит в массиве минимальный по модулю элемент и заменяет им все элементы с...

Многопоточность С++ - C++
Добрый вечер! написал вот такую программку. std::vector&lt;std::thread&gt; threads; std::recursive_mutex mutex; for (int i...

Многопоточность c++ - C++
Добрый день! Я только начинаю изучать многозадачность в c++ и у меня возник вопрос о том как возможно использовать один объект разными...

Многопоточность - C++
Не особо понимаю мнопоточность в с++. Есть задание типа.... Сделать программу, иммитирующую работу одновременно двух конечных автоматов....


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
daarg
0 / 0 / 1
Регистрация: 05.11.2008
Сообщений: 164
10.10.2010, 10:37  [ТС]     WaitForSingleObject и многопоточность #2
Разобрался сам
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru