VPF::[C++ Многопоточность] Массивы, строки

neomax38

Дата 8.4.2012, 13:45 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 27
Регистрация: 15.12.2010

Репутация: нет
Всего: нет

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

Требуется заменить операции. В С++ не шарю

Операции:
В родительском процессе делается выбор: либо вставка одной строки в другую с заданного символа, либо замена отрицательных элементов массива их квадратами.

Код


#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;
}

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Центр помощи \| Следующая тема »