синхронизация работы с совместно используемой памятью(семафоры)

@greenEYE · Регистрация: 30.11.2011

Author24 — интернет-сервис помощи студентам

делаю передачу данных через совместно используемую память,в её качестве используется структура shared_use.

C

typedef struct shared_use
{
    sem_t sem;
    int array[INTERMEDIATE_SIZE];
 
} shared_use;

как видно из кода,один из членов структуры является семафор,я инициализирую этот семафор в родителе(всего 2 процесса):

C

1	sem_init(&shared_stuff->sem,0,0);

shared_stuff - переменная типа указатель на структуру shared_use

после того,как дочерний совершит нужную работу он делает

C

1	sem_post(&shared_stuff->sem);

родитель,в свою очередь,ждёт дочерний процесс

C

1	sem_wait(&shared_stuff->sem);

программа залипает,то есть как-будто sem_post не работает
проблема именно в семафорах,тк при синхронизации с помощью обычного инта всё работает.

на всякий случай весь код :

C

#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/time.h>
#include <semaphore.h>
#include <sys/shm.h>
 
#define PART_SIZE 80000
#define INTERMEDIATE_SIZE 160000
#define GLOBAL_SIZE 320000
 
typedef struct shared_use
{
    sem_t sem;
    int writed;
    int array[INTERMEDIATE_SIZE];
 
} shared_use;
 
void write_to_inputfile(char *filename);
void read_from_file(char *filename,int *array1,int *array2,int *array3,int *array4);
void write_to_outputfile(char *filename,int *array);
void shell_sort(int *array,int n);
void merge_sort(int *array1,int *array2,int *result,int partsize);
void time_start();
void time_stop();
 
int arr1[PART_SIZE],arr2[PART_SIZE],arr3[PART_SIZE],arr4[PART_SIZE];
int in_arr1[INTERMEDIATE_SIZE],in_arr2[INTERMEDIATE_SIZE];
int final_array[GLOBAL_SIZE];
 
pid_t fork_result;
 
sem_t sm;
int res;
 
struct timeval tim;
double time_1,time_2;
 
void *shared_memory = (void *)0;
shared_use *shared_stuff;
int shmid;
 
int main(int argc,char *argv[])
{
 
    if (argc != 3)
    {
        perror("program format: program <input file> <output file>");
        exit(EXIT_FAILURE);
    }
 
    write_to_inputfile(argv[1]);
    read_from_file(argv[1],arr1,arr2,arr3,arr4);
 
    time_start();
 
    fork_result = fork();
    if(fork_result == -1)
    {
        fprintf(stderr,"Fork failure");
        exit(EXIT_FAILURE);
    }
 
    if(fork_result == 0)
    {
        sleep(2);
        shmid = shmget((key_t)123,sizeof(shared_use),0666 | IPC_CREAT);
        if(shmid == -1)
        {
            fprintf(stderr,"shmget failed\n");
            exit(EXIT_FAILURE);
        }
 
        shared_memory = shmat(shmid,(void *)0,0);
        if(shared_memory == (void *)-1)
        {
            fprintf(stderr,"shmat failed\n");
            exit(EXIT_FAILURE);
        }
 
        shared_stuff = (shared_use *)shared_memory;
 
        shell_sort(arr3,PART_SIZE);
        shell_sort(arr4,PART_SIZE);
        merge_sort(arr3,arr4,in_arr2,PART_SIZE);
 
        int i = 0;
        for(i; i < INTERMEDIATE_SIZE;i++)
            shared_stuff->array[i] = in_arr2[i];
        //shared_stuff->writed = 0;
 
        sem_post(&shared_stuff->sem);
 
        if(shmdt(shared_memory) == -1)
        {
            fprintf(stderr,"shmdt failed\n");
            exit(EXIT_FAILURE);
        }
 
        exit(EXIT_SUCCESS);
    }
    else
    {
 
        shmid = shmget((key_t)123,sizeof(shared_use),0666 | IPC_CREAT);
        if (shmid == -1)
        {
            fprintf(stderr,"shmget failed\n");
            exit(EXIT_FAILURE);
        }
 
        shared_memory = shmat(shmid,(void *)0,0);
        if (shared_memory == (void *)-1)
        {
            fprintf(stderr,"shmat failed\n");
            exit(EXIT_FAILURE);
        }
 
        shared_stuff = (shared_use *)shared_memory;
       // shared_stuff->writed = 1;
        res = sem_init(&shared_stuff->sem,0,0);
        if(res != 0)
        {
            perror("Semaphore init failed\n");
            exit(EXIT_FAILURE);
        }
 
        shell_sort(arr1,PART_SIZE);
        shell_sort(arr2,PART_SIZE);
 
        merge_sort(arr1,arr2,in_arr1,PART_SIZE);
        sem_wait(&shared_stuff->sem);
       /* while(shared_stuff->writed)
        {
            ;
        } */
 
        merge_sort(in_arr1,shared_stuff->array,final_array,INTERMEDIATE_SIZE);
        time_stop();
 
        if(shmdt(shared_memory) == -1)
        {
            fprintf(stderr,"shmdt failed\n");
            exit(EXIT_FAILURE);
        }
 
        if(shmctl(shmid,IPC_RMID,0) == -1)
        {
            fprintf(stderr,"shmctl(IPC_RMID) failed\n");
            exit(EXIT_FAILURE);
        }
    }
    printf("%.6lf seconds\n",time_2-time_1);
    write_to_outputfile(argv[2],final_array);
    return EXIT_SUCCESS;
}
 
void write_to_inputfile(char *filename)
{
    FILE *fo;
    fo = fopen(filename,"w");
    int size = GLOBAL_SIZE;
 
    if(fo == 0)
    {
        perror(filename);
        exit(EXIT_FAILURE);
    }
 
    while(size--)
        fprintf(fo,"%d ",1 + rand() % 9);
    fclose(fo);
}
 
void read_from_file(char *filename,int *arr1,int *arr2,int *arr3,int *arr4)
{
    FILE *fo;
    fo = fopen(filename,"r");
    int size = PART_SIZE;
 
    if(fo == 0)
    {
        perror(filename);
        exit(EXIT_FAILURE);
    }
 
    while(size--)
        fscanf(fo,"%d",arr1++);
    size = PART_SIZE;
    while(size--)
        fscanf(fo,"%d",arr2++);
    size = PART_SIZE;
    while(size--)
        fscanf(fo,"%d",arr3++);
    size = PART_SIZE;
    while(size--)
        fscanf(fo,"%d",arr4++);
 
    fclose(fo);
}
 
void write_to_outputfile(char *filename,int *array)
{
    FILE *fo;
    fo = fopen(filename,"w");
    int size = GLOBAL_SIZE;
 
    if(fo == 0)
    {
        perror(filename);
        exit(EXIT_FAILURE);
    }
 
    while(size--)
        fprintf(fo,"%d ",*array++);
 
    fclose(fo);
}
 
void shell_sort(int* a, int n)
{
    int step = n / 2;
    int i,j;
 
    while (step > 0)
    {
        for (i = 0; i < n - step; i++)
        {
            j = i;
            while ((j >= 0) && (a[j] > a[j + step]))
            {
                int buf = a[j];
                a[j] = a[j + step];
                a[j + step] = buf;
                j--;
            }
        }
        step /= 2;
    }
}
 
void merge_sort(int *array1,int *array2,int *result,int partsize)
{
    int i = 0,j = 0,index = 0;
 
    while(i < partsize && j < partsize)
    {
        if(array1[i] > array2[j])
            result[index++] = array2[j++];
        else
            result[index++] = array1[i++];
    }
 
    while(i < partsize)
        result[index++] = array1[i++];
 
    while(j < partsize)
        result[index++] = array2[j++];
}
 
void time_start()
{
    gettimeofday(&tim, NULL);
    time_1 = tim.tv_sec + (tim.tv_usec/1000000.0);
}
 
void time_stop()
{
    gettimeofday(&tim, NULL);
    time_2 = tim.tv_sec + (tim.tv_usec/1000000.0);
}

@dstat · 13.10.2013, 14:31

Надо

C++

1	res = sem_init(&shared_stuff->sem,1,0);

читаем доку
http://pubs.opengroup.org/onli... _init.html

C++

1	int sem_init(sem_t *sem, int pshared, unsigned int value);

If the pshared argument has a non-zero value, then the semaphore is shared between processes; in this case, any process that can access the semaphore sem can use sem for performing sem_wait(), sem_trywait(), sem_post(), and sem_destroy() operations

Новые блоги и статьи
Как работать с GraphQL на TypeScript InfoMaster 08.01.2025 Введение в GraphQL и TypeScript В современной разработке веб-приложений GraphQL стал мощным инструментом для создания гибких и эффективных API. В сочетании с TypeScript, эта технология. . .	Счётчик на базе сумматоров + регистров и генератора сигналов согласования. Hrethgir 07.01.2025 Создан с целью проверки скорости асинхронной логики: ранее описанного сумматора и предополагаемых fast регистров. Регистры созданы на базе ранее описанного, предполагаемого fast триггера. То-есть. . .	Как перейти с Options API на Composition API в Vue.js BasicMan 06.01.2025 Почему переход на Composition API актуален В мире современной веб-разработки фреймворк Vue. js продолжает эволюционировать, предлагая разработчикам все более совершенные инструменты для создания. . .	Архитектура современных процессоров inter-admin 06.01.2025 Процессор (центральный процессор, ЦП) является основным вычислительным устройством компьютера, которое выполняет обработку данных и управляет работой всех остальных компонентов системы. Архитектура. . .	История создания реляционной модели баз данных, правила Кодда Programming 06.01.2025 Предпосылки создания реляционной модели В конце 1960-х годов компьютерная индустрия столкнулась с серьезными проблемами в области управления данными. Существовавшие на тот момент модели данных -. . .	Полезные поделки на Arduino, которые можно сделать самому raxper 06.01.2025 Arduino как платформа для творчества Arduino представляет собой удивительную платформу для технического творчества, которая открывает безграничные возможности для создания уникальных проектов. Эта. . .
Подборка решений задач на Python IT_Exp 06.01.2025 Целью данной подборки является предоставление возможности ознакомиться с различными задачами и их решениями на Python, что может быть полезно как для начинающих, так и для опытных программистов. . . .	С чего начать программировать микроконтроллеры raxper 06.01.2025 Введение в мир микроконтроллеров Микроконтроллеры стали неотъемлемой частью современного мира, окружая нас повсюду: от простых бытовых приборов до сложных промышленных систем. Эти маленькие. . .	Из чего собрать игровой компьютер inter-admin 06.01.2025 Сборка игрового компьютера требует особого внимания к выбору комплектующих и их совместимости. Правильно собранный игровой ПК не только обеспечивает комфортный геймплей в современных играх, но и. . .	Обновление сайта www.historian.by Reglage 05.01.2025 Обещал подвести итоги 2024 года для сайта. Однако начну с того, что изменилось за неделю. Добавил краткий урок по последовательности действий при анализе вредоносных файлов и значительно улучшил урок. . .	Как использовать GraphQL в C# с HotChocolate Programming 05.01.2025 GraphQL — это современный подход к разработке API, который позволяет клиентам запрашивать только те данные, которые им необходимы. Это делает взаимодействие с API более гибким и эффективным по. . .	Модель полного двоичного сумматора с помощью логических операций (python) AlexSky-coder 04.01.2025 def binSum(x:list, y:list): s=^y] p=x and y for i in range(1,len(x)): s. append((x^y)^p) p=(x and y)or(p and (x or y)) return s x=list() y=list()

	13.10.2013, 14:31