почему Pthread Signal от main, зависает код? - PullRequest
Новая
       5

почему Pthread Signal от main, зависает код?

0 голосов
/ 10 ноября 2018

Требования к образцу приложения, создаваемого с использованием pthread, приведены ниже:

  1. Из основного потока создается отдельный поток с использованием Pthread
  2. Внутри потока, Mutex заблокирован, счетчик считаетзначение и цикл while увеличиваются, в то время как для максимального значения установлено значение 10.
  3. после окончания цикла мьютекс разблокируется.

Вышеприведенное требование, которое я пытался выполнитьиспользуя pthread

Код показан ниже: 

#include <pthread.h>
#include <stdio.h>
pthread_mutex_t count_mutex;
pthread_cond_t count_threshold_cv;

int samples = 10;
int count = 0;

struct example
{
    int i;
    int a;
};

void *inc_x(void *x_void_ptr)
{
    pthread_mutex_lock(&count_mutex);
    printf("Thread is locked \n");

    while(count < samples)
    {
    printf("inside While loop \n");

    struct example *E2_ptr;
    E2_ptr = (struct example *)x_void_ptr;
    printf("inside thread count = %d\n",count);
    E2_ptr->a = count;
    E2_ptr->i = (count + 1);
    count ++;
    //pthread_cond_wait(&count_threshold_cv, &count_mutex);
    }

    pthread_mutex_unlock(&count_mutex);
    printf ( "\n Test Successful for Thread\n");

    pthread_exit(NULL);
}

int main()
{

    int x = 100, y = 0,i = 0;
    struct example *E1_ptr;

    E1_ptr->a = 0;
    E1_ptr->i = 0;

    printf("Before\t E1_ptr->a = %d\t, E1_ptr->i = %d\n",E1_ptr->a,E1_ptr->i);


    pthread_t inc_x_thread;


    if(pthread_create(&inc_x_thread, NULL, inc_x, E1_ptr))
    {
    printf("Error creating thread\n");
    }


    if(pthread_join(inc_x_thread, NULL))
    {
    printf("Error joining thread\n");
    }

    for(i  = 0; i<(samples-1); i++)
    {
    if(pthread_cond_signal(&count_threshold_cv))
    {
         printf("Error Signaling thread at sample = %d\n",i);
    }
    }


    printf("after\t E1_ptr->a = %d\t, E1_ptr->i = %d\n",E1_ptr->a,E1_ptr->i);

    pthread_mutex_destroy(&count_mutex);
    pthread_cond_destroy(&count_threshold_cv);
    pthread_exit (NULL);


    return 0;
}

Сомнение:

В приведенном выше коде поток выполняет свою функцию должным образом и завершается.Как только условие применено, то есть показанный ниже код не закомментирован, 

pthread_cond_wait(&count_threshold_cv, &count_mutex);

Затем поток останавливается после 1-й итерации цикла while, как и ожидалось.Сигнал генерируется с основного с помощью кода, показанного ниже: 

for(i  = 0; i<(samples-1); i++)
{
    if(pthread_cond_signal(&count_threshold_cv))
    {
         printf("Error Signaling thread at sample = %d\n",i);
    }
}

заметил, что сигнал никогда не отправляется.

Может кто-нибудь, пожалуйста, направьте меня, где я иду не так.Я новичок в Pthreads.

Заранее спасибо.

1 Ответ

0 голосов
/ 10 ноября 2018

count_mutex и count_threshold_cv не инициализированы, добавьте: 

int main()
{
    pthread_mutex_init(&count_mutex, NULL);
    pthread_cond_init(&count_threshold_cv, NULL);
    //...

E1_ptr не инициализировано.Есть много способов ее решения:

Вы можете позвонить malloc, чтобы выделить память: 

struct example *E1_ptr = malloc(sizeof(struct example));

E1_ptr->a = 0;
E1_ptr->i = 0;

или удерживать указатель на локальную переменную: 

struct example ex;
struct example *E1_ptr = &ex; //malloc(sizeof(struct example));

E1_ptr->a = 0;
E1_ptr->i = 0;

или

struct example ex;
ex.a = 0;
ex.i = 0;

затем создать поток с функцией pthread_create(&inc_x_thread, NULL, inc_x, &ex)

pthread_cond_signal не ждет.Если поток заблокирован условной переменной pthread_cond_signal, функция разблокирует этот поток, в противном случае немедленно возвращается без ожидания и ничего не делает.Таким образом, ваш цикл for с 10 итерациями выполняется как можно быстрее, без ожидания вызова pthread_cond_wait.Так что можете переписать ваш цикл for в бесконечный цикл, вызывая pthread_cond_signal несколько раз.

if(pthread_create(&inc_x_thread, NULL, inc_x, E1_ptr)) {
   printf("Error creating thread\n");
} 

while(1) { // INFINITE LOOP
    if(pthread_cond_signal(&count_threshold_cv)) {
         printf("Error Signaling thread at sample = %d\n",i);
    }

    if (taskDone) // testing global flag, if 1 break
        break; // it means inc_x thread has ended
}

if(pthread_join(inc_x_thread, NULL)) { // it was pointed out in comment
printf("Error joining thread\n"); // you need to join at the end of main function
}

taskDone является глобальным int , со значением по умолчанию 0.Он устанавливается на 1 до вызова pthread_exit в функции inc_x.Установка / проверка taskDone должна быть заключена в некоторый механизм синхронизации, например, путем добавления нового мьютекса или использования count_mutex.

...