4 //#include "cds_threads.h"
7 #include "model-assert.h"
12 static queue_t *queue;
13 static thrd_t *threads;
14 static unsigned int *input;
15 static unsigned int *output;
16 static int num_threads;
20 thrd_t curr = thrd_current();
22 for (i = 0; i < num_threads; i++)
23 if (curr.priv == threads[i].priv)
31 static void main_task(void *param)
33 int pid = *((int *)param);
36 enqueue(queue, input[0]);
37 succ1 = dequeue(queue, &output[0]);
38 //printf("Dequeue: %d\n", output[0]);
41 enqueue(queue, input[1]);
42 succ2 = dequeue(queue, &output[1]);
46 int user_main(int argc, char **argv)
50 unsigned int in_sum = 0, out_sum = 0;
52 queue = (queue_t *)calloc(1, sizeof(*queue));
56 threads = (thrd_t *)malloc(num_threads * sizeof(thrd_t));
57 param = (int *)malloc(num_threads * sizeof(*param));
58 input = (unsigned *)calloc(num_threads, sizeof(*input));
59 output = (unsigned *)calloc(num_threads, sizeof(*output));
61 init_queue(queue, num_threads);
62 for (i = 0; i < num_threads; i++) {
64 thrd_create(&threads[i], main_task, ¶m[i]);
66 for (i = 0; i < num_threads; i++)
67 thrd_join(threads[i]);
69 for (i = 0; i < num_threads; i++) {
73 for (i = 0; i < num_threads; i++)
74 printf("input[%d] = %u\n", i, input[i]);
75 for (i = 0; i < num_threads; i++)
76 printf("output[%d] = %u\n", i, output[i]);
79 MODEL_ASSERT(in_sum == out_sum);