barrier.c

来自「linux下的多线程调试工具」· C语言 代码 · 共 37 行

#define _XOPEN_SOURCE 600

#include <pthread.h>
#include <stdio.h>
#include <time.h>
#include "alias.h"

struct timespec wait = {0, 10000000};
struct timespec rem;
#define WAIT nanosleep (&wait, &rem)

pthread_barrier_t barrier;
FILE *fd;

void *func (void *arg) {
    new_thread_alias (fd, "func");
    WAIT;
    pthread_barrier_wait (&barrier);
}

int main () {  
    pthread_t thread;

    fd = alias_init ("alias");
    new_thread_alias (fd, "main");
    new_object_alias (fd, &barrier, "barrier");

    pthread_barrier_init (&barrier, NULL, 2);
    pthread_create (&thread, NULL, func, NULL);
    pthread_barrier_wait (&barrier);
    pthread_join (thread, NULL);
    pthread_barrier_destroy (&barrier);

    return 0;
}