Многопоточность

@kess · Регистрация: 08.12.2008

Есть такая трудность:
2 потока, первый считает, а второй каждом 10мс такте пишет в базу данных то что посчитал первый.

делаю так:

C++

FirstThread::Execute
   {
       SecondThread->Resume();
       SecondThread->Suspend();
       Count (); //функция вычислений
   }

примерно раз в 20 секунд программа пишет в базу один и тот же такт дважды. как решить данную проблему?

З.Ы. я понимаю что мой подход в корне не верный и надо использовать объекты синхронизации, но почитав при них чё то ничё не нашёл ПОМОГИТЕ ПЛИИИЗ!!!

@mik-a-el · 28.01.2009, 17:37

Сообщение от kess

примерно раз в 20 секунд программа пишет в базу один и тот же такт дважды. как решить данную проблему?

Потому что потоки у вас не синхронизированы.

Вообще, при такой реализации, многопоточность не имеет смысла. Почему бы вместо запуска второго потока не вызвать обычную функцию?

Добавлено через 3 минуты 45 секунд

Сообщение от kess

я понимаю что мой подход в корне не верный и надо использовать объекты синхронизации

http://www.cyberguru.ru/progra... intro.html

@kess · 28.01.2009, 18:22 **[ТС]**

Сообщение от mik-a-el

Потому что потоки у вас не синхронизированы.

Вообще, при такой реализации, многопоточность не имеет смысла. Почему бы вместо запуска второго потока не вызвать обычную функцию?

Добавлено через 3 минуты 45 секунд

http://www.cyberguru.ru/progra... intro.html

я прочитал то что вы мне указали но не могу понять какая мне от этого польза в конкретном примере
у меня первый поток не останавливаясь считает время на 1 ядре процессора ,а второй просто должен запускаться раз в 10 милисекунд и писать информацию а бд при этом счёт времени ведёт 1 поток так как его вычисления ведуться в реальном времени

@mik-a-el · 28.01.2009, 18:55

Выложите код метода второго потока.

Добавлено через 9 минут 53 секунды

Сообщение от kess

я прочитал то что вы мне указали но не могу понять какая мне от этого польза в конкретном примере

Вы хотели узнать о синхронизации потоков? Вот оно вам.

@kess · 29.01.2009, 00:09 **[ТС]**

Сообщение от mik-a-el

Выложите код метода второго потока.

Добавлено через 9 минут 53 секунды

Вы хотели узнать о синхронизации потоков? Вот оно вам.

прошу прощения что долго не отвечал!
да не имеет значения просто для простоты можно потоково выкидывать номер такта в файл

моя задача научиться приостанавливать поток так что бы он жестко прописывал каждый такт при этом потоки работают на разных ядрах проца или на разных логических процах (Hyper Threading)
это делается потому что у меня тамер грузит один проц под максимум на 100 % и второму потоку не выделяется процессорного времени другой таймер использовать не могу не хватает точности счёта времени к тому же на первом проце крутиться ещё 17 математических функций по численному интегрированию и я просто не успеваю

@mik-a-el · 29.01.2009, 10:35

Сообщение от kess

это делается потому что у меня тамер грузит один проц под максимум на 100 %

Многовато для таймера, не задумывались?

Сообщение от kess

и второму потоку не выделяется процессорного времени

Если второй поток заводится только по этой причине, то это бред.

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

Советую еще раз перечитать указанную статью. Там есть все, что вам нужно.

@kess · 29.01.2009, 17:07 **[ТС]**

Сообщение от mik-a-el

Многовато для таймера, не задумывались?

Тамер работает на QueryPerformanceCounter & Frequency поэтому загрузка ЦП 100%.

Если второй поток заводится только по этой причине, то это бред.

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

Советую еще раз перечитать указанную статью. Там есть все, что вам нужно.

То что я делал не правильно я это понимаю прекрасно. Я с многопоточностью столкнулся первый раз поэтому могу тупить и задавать глупые вопросы.

А если по делу попробовал создавать событие CreateEvent:

C++

void __fastcall TTasks::CommonUpdate()
   {
      DWORD dw = WaitForSingleObject(hEvent,INFINITE);
      out<<Dispatcher->Secund<<"."<<Dispatcher->HunMillSec<<"."<<Dispatcher->TenMillSec<<'\n';
      ResetEvent(hEvent);
   }

это был поток записи, а второй (основной) поток должен работать не останавливаясь:

C++

QueryPerformanceCounter(&ETIME);
         do
            {
               Synchronize(Dispatcher->Run);
               SetEvent(hEvent);
               do
                  {
                     QueryPerformanceCounter(&STIME);
                     DELTA=(STIME.QuadPart-ETIME.QuadPart)/FREQ;
                  }
               while (DELTA < 0.01);
 
               QueryPerformanceCounter(&ETIME);
            }
         while(!Terminated);

Я так понял что если поставить событие в сигнальное состояние (SetEvent) то поток записи может работать, а при ResetEvent() он ждёт пока состояние не станет опять сигнальным.

Но в такой реализации ResetEvent() устанавливает несигнальное состояние и всё т.е. SetEvent не срабатывает.

@mik-a-el Администратор 79877 / 48440 / 244 Регистрация: 10.04.2006 Сообщений: 13,126
	28.01.2009, 17:37	2
	Сообщение от kess примерно раз в 20 секунд программа пишет в базу один и тот же такт дважды. как решить данную проблему? Потому что потоки у вас не синхронизированы. Вообще, при такой реализации, многопоточность не имеет смысла. Почему бы вместо запуска второго потока не вызвать обычную функцию? Добавлено через 3 минуты 45 секунд Сообщение от kess я понимаю что мой подход в корне не верный и надо использовать объекты синхронизации http://www.cyberguru.ru/progra... intro.html 0

@kess 0 / 0 / 0 Регистрация: 08.12.2008 Сообщений: 27
	28.01.2009, 18:22 [ТС]	3
	Сообщение от mik-a-el Потому что потоки у вас не синхронизированы. Вообще, при такой реализации, многопоточность не имеет смысла. Почему бы вместо запуска второго потока не вызвать обычную функцию? Добавлено через 3 минуты 45 секунд http://www.cyberguru.ru/progra... intro.html я прочитал то что вы мне указали но не могу понять какая мне от этого польза в конкретном примере у меня первый поток не останавливаясь считает время на 1 ядре процессора ,а второй просто должен запускаться раз в 10 милисекунд и писать информацию а бд при этом счёт времени ведёт 1 поток так как его вычисления ведуться в реальном времени 0

@mik-a-el Администратор 79877 / 48440 / 244 Регистрация: 10.04.2006 Сообщений: 13,126
	28.01.2009, 18:55	4
	Выложите код метода второго потока. Добавлено через 9 минут 53 секунды Сообщение от kess я прочитал то что вы мне указали но не могу понять какая мне от этого польза в конкретном примере Вы хотели узнать о синхронизации потоков? Вот оно вам. 0

@kess 0 / 0 / 0 Регистрация: 08.12.2008 Сообщений: 27
	29.01.2009, 00:09 [ТС]	5
	Сообщение от mik-a-el Выложите код метода второго потока. Добавлено через 9 минут 53 секунды Вы хотели узнать о синхронизации потоков? Вот оно вам. прошу прощения что долго не отвечал! да не имеет значения просто для простоты можно потоково выкидывать номер такта в файл моя задача научиться приостанавливать поток так что бы он жестко прописывал каждый такт при этом потоки работают на разных ядрах проца или на разных логических процах (Hyper Threading) это делается потому что у меня тамер грузит один проц под максимум на 100 % и второму потоку не выделяется процессорного времени другой таймер использовать не могу не хватает точности счёта времени к тому же на первом проце крутиться ещё 17 математических функций по численному интегрированию и я просто не успеваю 0

@mik-a-el Администратор 79877 / 48440 / 244 Регистрация: 10.04.2006 Сообщений: 13,126
	29.01.2009, 10:35	6
	Сообщение от kess это делается потому что у меня тамер грузит один проц под максимум на 100 % Многовато для таймера, не задумывались? Сообщение от kess и второму потоку не выделяется процессорного времени Если второй поток заводится только по этой причине, то это бред. В той реализации, что у вас, вы вновь запускаете второй поток и тут же, не беспокоясь о том, отработал он или нет, приостанавливаете его. Советую еще раз перечитать указанную статью. Там есть все, что вам нужно. 0

Опции темы