Блог

Я пытаюсь написать многопоточную программу и сталкиваюсь с некоторыми проблемами.

После того, как я запустил main.c , и я получаю

i: 0
новый поток 0
новый поток 1
i: 1
i: 1

 //main.c
#include <pthread.h>
#include <stdio.h>
#include <stdint.h>
void* routine(void* arg)
{
    int id = (intptr_t) arg;
    printf("new thread %dn", id);
    pthread_exit((void*)(intptr_t) id);
}
int main()
{
    pthread_t t[2];
    int i;
    for(i=0; i<2; i  )
    {
        int ret = pthread_create (amp;t[i], NULL, amp;routine,  (void *)(intptr_t) i);
        if(ret != 0) {
            printf("Error: pthread_create() failedn");
            return -1;
        }
    }
    int id;
    /////////here
    for(i=0; i<2; i  )
    {
        printf("i: %dn",i);
        pthread_join(t[i], (void **)amp;id);
    }
    /////////here
    pthread_exit(NULL);
}
  

Мои проблемы

• Почему последний цикл выполняется трижды?
• Если я дважды изменяю pthread_t t[2] pthread_t t и создаю, можно ли дважды вызвать pthread_join ?

Спасибо, что уделили время чтению моего вопроса.

Сначала добавьте еще несколько отладочных журналов:

 int id;
for(i=0; i<2; i  )
{
    printf("i: %dn",i);
    pthread_join(t[i], (void **)amp;id);
    printf("id[%d]: %dn", i, id);
}
  

Повторно запустите и запомните результат.

Затем измените его, чтобы он выглядел следующим образом

 int id;
for(i=0; i<2; i  )
{
    void * pv;   
    printf("i: %dn",i);
    pthread_join(t[i], amp;pv); /* Add error checking here! */
    id = (intptr_t) pv;
    printf("id: %dn", id);
}
  

Повторно запустите и сравните с предыдущей версией.

Как правило,:

Если вы сталкиваетесь с кажущейся необходимостью приведения в C (не C ), всегда подумайте дважды, так как есть только очень, очень, очень редкие случаи, когда приведение в C необходимо, а не просто скрывает ошибку программирования, отключая компилятор.