Форум программистов, компьютерный форум, киберфорум
C/C++: WinAPI
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.58/19: Рейтинг темы: голосов - 19, средняя оценка - 4.58
6 / 6 / 0
Регистрация: 22.02.2010
Сообщений: 67

Синхронизация потоков

26.03.2010, 23:26. Показов 3635. Ответов 2
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Здравствуйте, уважаемые форумчане!
Нужно мне написать прогу на синхронизацию. Задача такая: есть поток, пишущий в канал по-байтно (вернее по целому числу), и три потока, читающие из канала. Читатели ждут, пока писатель не записал в канал очередной байт. После этого они считывают байт (обязательно все должны считать), а потом ждут пока будет записан следующий байт и т.д. Думал я сделать все на событиях. При этом одно событие с ручным сбросом связывается с писателем, и по одному событию с автосбросом с каждым читателем. Все потоки находятся в бесконечном цикле. Читатели в начале цикла ждут, пока писатель не запишет очередной байт. Писатель записывает байт и вызывает PulseEvent(), чтобы освободить все ожидающие потоки и сразу же снова сбросить событие. Если использовать для этого SetEvent()-ResetEvent(), то в промежутке между их вызовами некоторые читатели могут несколько раз считать байт. Если для писателя использовать событие с автосбросом, то оно освободит только одного читателя, а нужно всех. Затем писатель начинает ждать ВСЕХ читателей. Все получается здорово при одном читателе, а вот при нескольких - лажа: не все читатели успевают сработать, и возникает взаимная блокировка. Подскажите, пожалуйста, что в моей архитектуре не верно? Как нужно сделать правильно?
Текст приложения:
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
#include <stdio.h>
#include <windows.h>
#include <process.h>
 
#define THREADS_NUM 3   //число читателей
#define N 30            //предел
 
//потоковая функция читателя
DWORD WINAPI HostFunc(void*);
//потоковая функция писателя
DWORD WINAPI ChanelFunc(LPVOID);
 
HANDLE HostEv[THREADS_NUM];  //события читателей
HANDLE ChanelEv;             //событие писателя
DWORD temp = 0;              //записываемая-читаемая величина
struct
{
  HANDLE hHost;
} Hosts[THREADS_NUM]; //потоки-читатели
HANDLE chanel;        //поток-писатель
 
int main(int argc, char argv[])
{
  //создаем события
  for(int i = 0; i < THREADS_NUM; i++)
  {
    HostEv[i] = CreateEvent(NULL, FALSE, FALSE, NULL);
  }
  ChanelEv = CreateEvent(NULL, TRUE, FALSE, NULL);
 
  for(int i = 0; i < THREADS_NUM; i++)
  {
    //запускаем читающие потоки
    Hosts[i].hHost = (HANDLE)_beginthreadex(NULL, 0, (unsigned int (__stdcall*)(void*))(HostFunc), (void*)i, 0, NULL);
    //запускаем поток-писатель
    chanel = (HANDLE)_beginthreadex(NULL, 0, (unsigned int (__stdcall*)(void*))ChanelFunc, NULL, 0, NULL);
  }
  getchar();
  return 0;
}
 
DWORD WINAPI HostFunc(void* i)
{
  while(temp != N)
  {
    WaitForSingleObject(ChanelEv, INFINITE);    //ждем записи
    printf("thread#%i-%i ", (int)(i), temp);    //просто выводим на консоль считанную величину
    SetEvent(HostEv[(int)i]);                   //сигнализируем писателю
  }
  return 0;
}
 
DWORD WINAPI ChanelFunc(LPVOID n)
{
  while(temp != N)
  {
    temp++;
    printf("\nchanel: %i ", temp);      //выводим на консоль записываемуюую величину
    PulseEvent(ChanelEv);                       //сигнализируем читателям
    WaitForMultipleObjects(THREADS_NUM, HostEv, TRUE, INFINITE);  //ожидаем ВСЕХ читателей
  }
  return 0;
}
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
26.03.2010, 23:26
Ответы с готовыми решениями:

Синхронизация потоков
Здравствуйте. Подскажите пожалуйста. У меня есть три потока. Мне нужно чтобы они запускались последовательно (1 - 2 -3). Подскажите как это...

Синхронизация потоков
Помогите обеспечить синхронизацию потоков const int j=20; hSemaphore = CreateSemaphore(NULL, 0, 1, NULL); DWORD __stdcall...

Синхронизация потоков
Вот код: #include &quot;iostream&quot; #include &quot;windows.h&quot; using namespace std; char* hydrogenContainer; char* oxygenContainer; int...

2
10 / 10 / 4
Регистрация: 12.07.2009
Сообщений: 86
27.03.2010, 00:11
Я бы сделал еще одно событие, которое означало бы что все читатели сработали и можно переходить к новой итерации, типа:
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
DWORD WINAPI HostFunc(void* i)
{
while(temp != N)
{
    WaitForSingleObject(ChanelEv, INFINITE); //ждем записи
    printf("thread#%i-%i ", (int)(i), temp); //просто выводим на консоль считанную величину
    SetEvent(HostEv[(int)i]); //сигнализируем писателю
    WaitForSingleObject(ChnlsFin, INFINITE); //ждем пока все считают
}
return 0;
}
 
DWORD WINAPI ChanelFunc(LPVOID n)
{
while(temp != N)
{
    temp++;
    printf("\nchanel: %i ", temp); //выводим на консоль записываемуюую величину
    PulseEvent(ChanelEv); //сигнализируем читателям
    WaitForMultipleObjects(THREADS_NUM, HostEv, TRUE, INFINITE); //ожидаем ВСЕХ читателей
    PulseEvent(ChnlsFin);//разрешаем читателям новую итерацию
}
return 0;
}
0
6 / 6 / 0
Регистрация: 22.02.2010
Сообщений: 67
27.03.2010, 20:36  [ТС]
Идея интересная и вроде бы верная, но все равно возникает взаимоблокировка (на произвольном шаге)
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
27.03.2010, 20:36
Помогаю со студенческими работами здесь

Синхронизация потоков
Добрый день. Помогите пожалуйста написать программу на С++ по синхронизации потоков. Задание такое: поток А формирует общий ресурс -...

Синхронизация потоков
Помогите синхронизировать два потока на Win32 Api. 1й выводит числовую последовательность, 2й - числа Фибоначчи. Выполняются по кругу. ...

Синхронизация потоков
Нужно: Выполнение нескольких арифметических операций разного приоритета. Оперировать с помощью мьютексов и кретических секций, как...

Синхронизация потоков
в общем есть код: DWORD WINAPI IndexSystemFile::GetFileFromDrive(void *DriveName){ long hFile = 0; int fRes = 0; ...

Синхронизация потоков
Как переделать с использованием mutex или еще чего нибудь? /*Три нити. Одна генерирует тройки чисел, вторая решает...


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

Или воспользуйтесь поиском по форуму:
3
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D
8Observer8 04.03.2026
Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .
SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий
8Observer8 02.03.2026
Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11680&amp;d=1772460536 Одним из. . .
Реалии
Hrethgir 01.03.2026
Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .
Ритм жизни
kumehtar 27.02.2026
Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .
SDL3 для Web (WebAssembly): Сборка библиотек: SDL3, Box2D, FreeType, SDL3_ttf, SDL3_mixer и SDL3_image из исходников с помощью CMake и Emscripten
8Observer8 27.02.2026
Недавно вышла версия 3. 4. 2 библиотеки SDL3. На странице официальной релиза доступны исходники, готовые DLL (для x86, x64, arm64), а также библиотеки для разработки под Android, MinGW и Visual Studio. . . .
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами
8Observer8 20.02.2026
Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .
Конвертировать закладки radiotray-ng в m3u-плейлист
damix 19.02.2026
Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .
Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI
Eddy_Em 18.02.2026
Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru