6 #include "model-assert.h"
10 static thrd_t *threads;
11 static unsigned int *input;
12 static unsigned int *output;
13 static int num_threads;
17 thrd_t curr = thrd_current();
19 for (i = 0; i < num_threads; i++)
20 if (curr.priv == threads[i].priv)
26 static void main_task(void *param)
29 int pid = *((int *)param);
33 //enqueue(queue, input[0]);
34 enqueue(queue, input[0]);
35 output[0] = dequeue(queue);
38 enqueue(queue, input[1]);
39 //output[1] = dequeue(queue);
40 //output[0] = dequeue(queue);
41 output[0] = dequeue(queue);
45 int user_main(int argc, char **argv)
54 unsigned int in_sum = 0, out_sum = 0;
56 queue = calloc(1, sizeof(*queue));
57 //MODEL_ASSERT(queue);
60 threads = malloc(num_threads * sizeof(thrd_t));
61 param = malloc(num_threads * sizeof(*param));
62 input = calloc(num_threads, sizeof(*input));
63 output = calloc(num_threads, sizeof(*output));
65 init_queue(queue, num_threads);
66 for (i = 0; i < num_threads; i++) {
68 thrd_create(&threads[i], main_task, ¶m[i]);
70 for (i = 0; i < num_threads; i++)
71 thrd_join(threads[i]);
73 for (i = 0; i < num_threads; i++) {
77 for (i = 0; i < num_threads; i++)
78 printf("input[%d] = %u\n", i, input[i]);
79 for (i = 0; i < num_threads; i++)
80 printf("output[%d] = %u\n", i, output[i]);
81 //MODEL_ASSERT(in_sum == out_sum);