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)
28 static void main_task(void *param)
32 int pid = *((int *)param);
36 succ1 = dequeue(queue, &input[0]);
39 enqueue(queue, input[1]);
45 enqueue(queue, input[0]);
46 printf("Enqueue %d.\n", 17);
48 succ1 = dequeue(queue, &input[0]);
50 printf("Thrd 2: Dequeue %d.\n", input[0]);
52 printf("Thrd 2: Dequeue NULL.\n");
54 } else if (pid % 3 == 1) {
57 enqueue(queue, input[1]);
58 printf("Enqueue %d.\n", 37);
60 succ1 = dequeue(queue, &input[0]);
62 printf("Thrd 3: Dequeue %d.\n", input[0]);
64 printf("Thrd 3: Dequeue NULL.\n");
65 } else if (pid %3 == 2) {
67 succ2 = dequeue(queue, &output[1]);
69 printf("Dequeue %d.\n", input[1]);
71 printf("Dequeue NULL.\n");
77 int user_main(int argc, char **argv)
86 unsigned int in_sum = 0, out_sum = 0;
88 queue = calloc(1, sizeof(*queue));
89 //MODEL_ASSERT(queue);
92 threads = malloc(num_threads * sizeof(thrd_t));
93 param = malloc(num_threads * sizeof(*param));
94 input = calloc(num_threads, sizeof(*input));
95 output = calloc(num_threads, sizeof(*output));
97 init_queue(queue, num_threads);
98 for (i = 0; i < num_threads; i++) {
100 thrd_create(&threads[i], main_task, ¶m[i]);
102 for (i = 0; i < num_threads; i++)
103 thrd_join(threads[i]);
105 for (i = 0; i < num_threads; i++) {
107 out_sum += output[i];
109 for (i = 0; i < num_threads; i++)
110 printf("input[%d] = %u\n", i, input[i]);
111 for (i = 0; i < num_threads; i++)
112 printf("output[%d] = %u\n", i, output[i]);
113 //MODEL_ASSERT(in_sum == out_sum);