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

Тема в разделе "C/C++/C#", создана пользователем neomax38, 24 апр 2012.

  1. neomax38

    neomax38 Гость

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

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

    Требуемые операции:
    В родительском процессе делается выбор: либо вставка одной строки в другую с заданного символа, либо замена отрицательных элементов массива их квадратами.
    Код (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;
    }
     
Загрузка...
Похожие Темы - [c++ Unix] Семафоры
  1. world77
    Ответов:
    1
    Просмотров:
    1.310

Поделиться этой страницей