Пробег между виртуальной функцией и pthread_create

Question

Когда я пытаюсь создать экземпляр класса с помощью виртуального метода и передать его в pthread_create, я получаю условие гонки, заставляя вызывающего абонента иногда вызывать базовый метод вместо производного метода, как он должен , После googling pthread vtable race я узнал, что это довольно известное поведение. Мой вопрос: какой хороший способ обойти это?

Код ниже демонстрирует это поведение при любой настройке оптимизации. Обратите внимание, что объект MyThread полностью сконструирован перед передачей pthread_create.

#include <errno.h> 
#include <pthread.h> 
#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 

struct Thread { 
    pthread_t thread; 

    void start() { 
     int s = pthread_create(&thread, NULL, callback, this); 
     if (s) { 
      fprintf(stderr, "pthread_create: %s\n", strerror(errno)); 
      exit(EXIT_FAILURE); 
     } 
    } 
    static void *callback(void *ctx) { 
     Thread *thread = static_cast<Thread*> (ctx); 
     thread->routine(); 
     return NULL; 
    } 
    ~Thread() { 
     pthread_join(thread, NULL); 
    } 

    virtual void routine() { 
     puts("Base"); 
    } 
}; 

struct MyThread : public Thread { 
    virtual void routine() { 

    } 
}; 

int main() { 
    const int count = 20; 
    int loop = 1000; 

    while (loop--) { 
     MyThread *thread[count]; 
     int i; 
     for (i=0; i<count; i++) { 
      thread[i] = new MyThread; 
      thread[i]->start(); 
     } 
     for (i=0; i<count; i++) 
      delete thread[i]; 
    } 

    return 0; 
} 

Answer 1

Единственная проблема здесь состоит в том, что при удалении объектов до порождал поток выполняет метод, поэтому к тому времени, когда ребенок деструктор уже выстрелил, и объект не существует больше.

Таким образом, это не имеет ничего общего с pthread_create или что-то еще, его время, вы не можете порождать поток, дать ему некоторые ресурсы и удалить их, прежде чем он сможет их использовать.

Попробуйте это, он покажет, как OBJS разрушаются от основной нити перед тем порождали нить использует их:

struct Thread { 
pthread_t thread; 
bool deleted; 

void start() { 
    deleted=false; 
    int s = pthread_create(&thread, NULL, callback, this); 
    if (s) { 
      fprintf(stderr, "pthread_create: %s\n", strerror(errno)); 
      exit(EXIT_FAILURE); 
    } 
} 
static void *callback(void *ctx) { 
    Thread *thread = static_cast<Thread*> (ctx); 
    thread->routine(); 
    return NULL; 
} 
~Thread() { 
    pthread_join(thread, NULL); 
} 

virtual void routine() { 
    if(deleted){ 
     puts("My child deleted me"); 
    } 
    puts("Base"); 
} 
}; 

struct MyThread : public Thread { 
virtual void routine() { 

} 
~MyThread(){ 
    deleted=true; 
} 

}; 

В другой стороны, если вы просто поместите сон в основном, прежде чем удалить их, вы будете никогда не возникает эта проблема, потому что порожденный поток использует действительные ресурсы.

int main() { 
const int count = 20; 
int loop = 1000; 

while (loop--) { 
    MyThread *thread[count]; 
    int i; 
    for (i=0; i<count; i++) { 
      thread[i] = new MyThread; 
      thread[i]->start(); 
    } 
    sleep(1); 
    for (i=0; i<count; i++) 
      delete thread[i]; 
} 

return 0; 
} 

Answer 2

Не делайте pthread_join (или любую другую реальную работу) в деструкторе. Добавьте метод join() в Thread и вызовите его перед удалением thread [i] в ​​main.

Если вы попытаетесь вызвать pthread_join в деструкторе, поток может все еще выполнять Thread :: rout(). Это означает, что он использует объект, который уже частично уничтожен.. Что произойдет? Кто знает? Надеемся, что программа быстро выйдет из строя.

---

Дополнительно:

• Если вы хотите наследовать тему, Thread :: ~ Тема должна быть объявлена ​​виртуальной.

• Проверьте все ошибки и обработайте их должным образом (что BTW не может быть сделано внутри деструктора).