Форум программистов, компьютерный форум, киберфорум
C/С++ под Linux
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.67/6: Рейтинг темы: голосов - 6, средняя оценка - 4.67
544 / 93 / 49
Регистрация: 16.12.2011
Сообщений: 317

Синхронизация процессов в linux

13.12.2013, 22:13. Показов 1202. Ответов 1
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Имеется следующий код, который по нажатию на клавишу "+" добавляет процесс, а по нажатию клавиши "-" удаляет процесс. Процессы выводят свои номера в консоли циклически. По нажатию на клавишу "q" программа прекращает свое выполнение.

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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
#include <ncurses.h> 
#include <unistd.h> 
#include <sys/wait.h> 
#include <signal.h> 
#include <string.h> 
#include <stdlib.h> 
   
bool printAllowed = false; 
bool killFlag = true; 
bool flag = false; 
int processesCount = 0; 
int currentProcessNumber = 0; 
static const char *colors[] = { "\x1B[0m", "\x1B[31m","\x1B[32m","\x1B[33m","\x1B[34m","\x1B[35m","\x1B[36m","\x1B[37m" }; 
   
struct sigaction printSignal, killSignal; 
   
void allowPrint(int sign){ 
  printAllowed = true; 
} 
   
void setKillFlag(int sign){ 
  killFlag = true; 
} 
   
int createProcess(pid_t pidArray[]){ 
   
  if(processesCount > 100) return 1; 
   
  pidArray[processesCount] = fork(); 
  processesCount++; 
   
  switch(pidArray[processesCount - 1]){ 
   
    case 0:{ 
      killFlag = false; 
      char buff[255]; 
      int colorNumber = (processesCount > 7)? 0 : processesCount; 
      sprintf(buff,"%sProcess %d || ", colors[colorNumber], processesCount); 
      while(!killFlag) { 
        usleep(10000); 
        if(printAllowed){ 
          for(int i = 0; i < strlen(buff); i++){ 
            if(killFlag) { return -1;}; 
            printf("%c", buff[i]); 
            refresh(); 
            usleep(50000); 
          } 
          printAllowed = false; 
          // signal to parent that process stop print
          kill(getppid(), SIGUSR2); 
        }
        // function pause() man pause
      }  
      return -1; 
    } 
   
    case -1: printf("%sError!", colors[1]); return 1; 
   
    default:  return 1; 
  } 
} 
   
bool killProcess(pid_t pidArray[]){ 
  if (processesCount <= 0) return 1; 
   
  processesCount--; 
  // stop last child process
  kill(pidArray[processesCount], SIGUSR2); 
  waitpid(pidArray[processesCount], NULL, NULL); 
  // if the process that printing now stopped
  if (currentProcessNumber >= processesCount){ 
    currentProcessNumber = 0; // start from beginning
    flag = true;  // flag last process by number
    killFlag = true; // flag of end printing current process
  } 
   
  return 1; 
} 
   
int controlProcesses(pid_t pidArray[]){ 
  halfdelay(1); 
  switch((char)getchar()){ 
  case '=': return createProcess(pidArray); 
  case '-': return killProcess(pidArray); 
  case 'q': return 0; 
  default: return 1; 
  } 
} 
   
void killAllProcesses(pid_t pidArray[]){ 
  if(pidArray[--processesCount] != 0) 
    for( ;processesCount >= 0; processesCount--){ 
      kill(pidArray[processesCount],SIGUSR2); 
      waitpid(pidArray[processesCount],NULL,NULL); 
    } 
} 
   
int main(){ 
   
  initscr(); 
  clear(); 
  noecho(); 
  refresh(); 
   
   
  printSignal.sa_handler = allowPrint; 
  sigaction(SIGUSR1,&printSignal,NULL); 
   
  killSignal.sa_handler = setKillFlag; 
  sigaction(SIGUSR2,&killSignal,NULL); 
   
  pid_t pidArray[100]; 
   
  while(int i = controlProcesses(pidArray)) { 
   
    if(i == -1) return 0; 
   
   
    if(killFlag && processesCount > 0){  // if current process stop printing
      killFlag = false; 
      if(currentProcessNumber >= processesCount - 1) currentProcessNumber = 0; // if the number of current process is last, start from beginning
      else if(!flag) currentProcessNumber++; // else if last stopped process wasn't the last by number go to next process
      flag = false; 
      kill(pidArray[currentProcessNumber], SIGUSR1); // signal to child process start the printing
    } 
    refresh(); 
  } 
  // stop all child processes
  killAllProcesses(pidArray); 
   
  clear(); 
  endwin(); 
  
  return 0; 
}
Собственно вопрос как с поимощью функции pause() или же ей подобным можно оптимизировать цикл while в следующем участке кода? Тоесть чтобы процесс печался только тогда когда когда получил сигнал и чтобы не было при этом "холостых циклов". А не постоянно проверялся killFlag флаг.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
while(!killFlag) { 
        usleep(10000); 
        if(printAllowed){ 
          for(int i = 0; i < strlen(buff); i++){ 
            if(killFlag) { return -1;}; 
            printf("%c", buff[i]); 
            refresh(); 
            usleep(50000); 
          } 
          printAllowed = false; 
          // signal to parent that process stop print
          kill(getppid(), SIGUSR2); 
        }
        // function pause() man pause
      }
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
13.12.2013, 22:13
Ответы с готовыми решениями:

Синхронизация процессов
Добрый вечер, форумчане! Имеется такая задача: Исходный процесс создает два программных информационных канала К1 и К2, канал...

Синхронизация процессов
Здравствуйте , помогите с синхронизацией процессов. Нужно создать 2 процесса дочерних и читать файл по 10 символов в течении 10 секунд либо...

Синхронизация процессов
Здравствуйте!Подскажите пожалуйста как выполнить следующее задание: Программа порождает иерархическое дерево процессов. Каждый процесс...

1
Псевдослучайный
1946 / 1146 / 98
Регистрация: 13.09.2011
Сообщений: 3,215
13.12.2013, 23:37
Можно использовать sigwait.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
13.12.2013, 23:37
Помогаю со студенческими работами здесь

Синхронизация процессов семафоры
у меня что то не получается за синхронизировать 4 процесса, тоесть я хочу чтобы выводила 1,2,3,4 оно выводит 3,1,2. Помогите пожалуйсто ...

Синхронизация процессов сигналами (надежная модель)
Задача: Начальный процесс является управляющим. Он принимает поток ввода с клавиатуры и контролирует дочерние процессы. По нажатию...

Синхронизация потоков в OC Linux
Здравствуйте. Помогите, пожалуйста, решить проблему. Решите классическую проблему «поставщик – потребитель» с использованием средств...

Debian Linux - Создание процессов (дед, отец, сын), fork();
Привет всем. Появилось у меня несколько вопросов по созданию процессов. Может будете ругаться, но реально не могу понять.. Уже гугл...

Синхронизация процессов
Добрый день уважаемые форумчане. Если ошибся разделом - поправьте. Вкратце опишу проблему. Есть терминальный сервер и некая...


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

Или воспользуйтесь поиском по форуму:
2
Ответ Создать тему
Новые блоги и статьи
Знаешь почему 90% людей редко бывают счастливыми?
kumehtar 14.04.2026
Потому что они ждут. Ждут выходных, ждут отпуска, ждут удачного момента. . . а удачный момент так и не приходит.
Фиксация колонок в отчете СКД
Maks 14.04.2026
Фиксация колонок в СКД отчета типа Таблица. Задача: зафиксировать три левых колонки в отчете. Процедура ПриКомпоновкеРезультата(ДокументРезультат, ДанныеРасшифровки, СтандартнаяОбработка) / / . . .
Настройки VS Code
Loafer 13.04.2026
{ "cmake. configureOnOpen": false, "diffEditor. ignoreTrimWhitespace": true, "editor. guides. bracketPairs": "active", "extensions. ignoreRecommendations": true, . . .
Оптимизация кода на разграничение прав доступа к элементам формы
Maks 13.04.2026
Алгоритм из решения ниже реализован на нетиповом документе, разработанного в конфигурации КА2. Задачи, как таковой, поставлено не было, проделанное ниже исключительно моя инициатива. Было так:. . .
Контроль заполнения и очистка дат в зависимости от значения перечислений
Maks 12.04.2026
Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: реализовать контроль корректности заполнения дат назначения. . .
Архитектура слоя интернета для сервера-слоя.
Hrethgir 11.04.2026
В продолжение https:/ / www. cyberforum. ru/ blogs/ 223907/ 10860. html Знаешь что я подумал? Раз мы все источники пишем в голове ветки, то ничего не мешает добавить в голову такой источник, который сам. . .
Подстановка значения реквизита справочника в табличную часть документа
Maks 10.04.2026
Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: при выборе сотрудника (справочник Сотрудники) в ТЧ документа. . .
Очистка реквизитов документа при копировании
Maks 09.04.2026
Алгоритм из решения ниже применим как для типовых, так и для нетиповых документов на самых различных конфигурациях. Задача: при копировании документа очищать определенные реквизиты и табличную. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru