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 /** Be careful, we must make these variables to be global so that they will be
27 * 'available' when the execution is generated */
29 unsigned int output1, output2;
31 static void main_task(void *param)
33 int pid = *((int *)param);
36 succ1 = dequeue(queue, &output1);
38 printf("Thrd 2: Dequeue %d.\n", output1);
40 printf("Thrd 2: Dequeue NULL.\n");
41 } else if (pid % 3 == 1) {
43 succ2 = dequeue(queue, &output2);
45 printf("Thrd 3: Dequeue %d.\n", output2);
47 printf("Thrd 3: Dequeue NULL.\n");
48 } else if (pid %3 == 2) {
50 enqueue(queue, input);
51 printf("Thrd 4 Enqueue %d.\n", input);
55 int user_main(int argc, char **argv)
64 unsigned int in_sum = 0, out_sum = 0;
66 queue = calloc(1, sizeof(*queue));
67 //MODEL_ASSERT(queue);
70 threads = malloc(num_threads * sizeof(thrd_t));
71 param = malloc(num_threads * sizeof(*param));
72 input = calloc(num_threads, sizeof(*input));
73 output = calloc(num_threads, sizeof(*output));
75 init_queue(queue, num_threads);
76 for (i = 0; i < num_threads; i++) {
78 thrd_create(&threads[i], main_task, ¶m[i]);
80 for (i = 0; i < num_threads; i++)
81 thrd_join(threads[i]);
83 for (i = 0; i < num_threads; i++) {
87 for (i = 0; i < num_threads; i++)
88 printf("input[%d] = %u\n", i, input[i]);
89 for (i = 0; i < num_threads; i++)
90 printf("output[%d] = %u\n", i, output[i]);
91 //MODEL_ASSERT(in_sum == out_sum);