c_cpp C语言-CS520

Posted 2021-05-14

#   ifdef DEBUG
    print_array(samples, s);
#   endif

pthread_t *thread_handles = malloc(thread_count * sizeof(pthread_t));
long thread;
for (thread = 0; thread < thread_count; thread++) {
    pthread_create(thread_handles + thread, NULL, Multiply, (void*) thread);
}
for (thread = 0; thread < thread_count; thread++) {
    pthread_join(*(thread_handles + thread), NULL);
}
void* Multiply(void* rank) {
    long my_rank = (long) rank;
    long i;
    long start = (long) (n / thread_count) * my_rank;
    long end = (long) (n / thread_count) * (my_rank + 1);
    for (i = start; i < end; i++) {
        *(array_Y + i) = *(array_X + i) * alpha;
    }
    return NULL;
}

void Usage(char* prog_name) {
    fprintf(stderr, "usage: %s <number of threads> <n>\n", prog_name);
    exit(0);
}

#include <pthread.h>
pthread_mutex_t mutex;
pthread_mutex_init(&mutex, NULL);
pthread_mutex_destroy(&mutex);
pthread_mutex_lock(&mutex);
pthread_mutex_unlock(&mutex);