[c++ Unix] Семафоры Многопоточность

  • Автор темы neomax38
  • Дата начала
N

neomax38

Гость
#1
Помогите переделать, найденный вариант:
В родительском процессе делается выбор: либо операция подсчета длины строки, либо операция подсчета суммы элементов числового массива. Вся необходимая информация вводится с клавиатуры и записывается в файл, который служит средством обмена данными между процессами. Дочерний процесс читает данные из файла, выполняет нужную операцию и записывает результат в тот же файл. Затем родительский процесс считывает результаты из файла и выводит их на экран.
Для синхронизации обмена между процессами используется два семафора, которые по очереди увеличивают и уменьшают счетчики.

помогите заменить на другие операции. В С++ не шарю

Требуемые операции:
В родительском процессе делается выбор: либо вставка одной строки в другую с заданного символа, либо замена отрицательных элементов массива их квадратами.
C++:
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <iostream>

#include <fcntl.h>
#include <sys/stat.h>
#include <semaphore.h>

#include <sys/types.h>
#include <unistd.h>


#define TEXT_SIZE 255
#define FILE_NAME "buffer1"

struct messsage //Структура для хранения данных
{ char selection;
char txt[200];
int n;
int A[20];} mes;
FILE* f; 

using namespace std;

// Имя семафора должно начинаться с символа /
#define SEM_NAME_1 "/semaphore1"
#define SEM_NAME_2  "/semaphore2"
//Функция родительского процесса
void parent(sem_t *semaphore1, sem_t *semaphore2) {
char st[TEXT_SIZE];
("Введите тип операции\n\r 1 - Для вычисления длины текста\n\r");
printf(" 2 - Для нахождения суммы элементов массива\n\r");
printf("Ваш выбор: ");
scanf("%c",st);
mes.selection=st[0];
if (mes.selection=='1') {
printf("Введите текст: ");
scanf("%s",st);
strcpy(mes.txt,st);
printf("Текст: %s\n",mes.txt);
}

else
if (mes.selection=='2') {
printf("Введите размер массива: ");
scanf("%s",st);
mes.n=atoi(st);
printf("Введите массив: ");
for (int i=0;i<mes.n;i++)
{scanf("%s",st);
mes.A[i]=atoi(st);		
printf("Элемент %d\n",mes.A[i]);}
}

else {
printf("Неверная операция\n");
return;
}
f=fopen(FILE_NAME,"w");
fprintf(f,"%c\n",mes.selection);
switch(mes.selection)
{case '1':fprintf(f,"%s\n",mes.txt);break;
case '2':
fprintf(f,"%d\n",mes.n);
for (int i=0;i<mes.n;i++)
fprintf(f,"%d\n",mes.A[i]);
break;
}
fclose(f);
sem_post(semaphore1);
sem_wait(semaphore2);
f=fopen(FILE_NAME,"r");
char *str = NULL;
size_t len = 0;
fscanf(f,"s",&str);
fclose(f);
printf("Результат: %s\n",str);
free(str);
sem_close(semaphore1);
sem_close(semaphore2);
sem_unlink(SEM_NAME_1);
sem_unlink(SEM_NAME_2);
}
//Функция дочернего процесса
void child(sem_t *semaphore1, sem_t *semaphore2) {
sem_wait(semaphore1);
char* st= new char(TEXT_SIZE);
char str[255];

f=fopen(FILE_NAME,"r");
fscanf(f,"%c\n",&mes.selection);
printf("Пришело %c\n",mes.selection);
switch(mes.selection) {
case '1':fscanf(f,"%s\n",&mes.txt);
printf("Пришел текст %s\n",mes.txt);
break;
case '2':fscanf(f,"%d",&mes.n);
for (int i=0;i<mes.n;i++)
{fscanf(f,"%d",&mes.A[i]);
printf("Массив %d\n",mes.A[i]);}
break;}
fclose(f); 
f=fopen(FILE_NAME,"w");
switch(mes.selection) {
case '1':
fprintf(f,"Длинна %d\n", strlen(mes.txt));
printf("%s\n",str);
break;
case '2':
int sum=0;
for (int i=0;i<mes.n;i++)
sum+=mes.A[i];
fprintf(f,"Сумма %d\n", sum);
break;
}
fclose(f);
sem_post(semaphore2);
sem_close(semaphore1);
sem_close(semaphore2);
}

int main(int argc, char* args[]) {
sem_t *semaphore1 = sem_open(SEM_NAME_1, O_CREAT, S_IRUSR | S_IWUSR, 0);
sem_t *semaphore2 = sem_open(SEM_NAME_2, O_CREAT, S_IRUSR | S_IWUSR, 0);
pid_t pid;
pid = fork();
if (pid!=0) {parent(semaphore1,semaphore2);}
else child(semaphore1,semaphore2);
return 0;
}