3 #include "cds_threads.h"
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 (std::this_thread::get_id() == threads[i].get_id())
28 static void main_task(void *param)
31 int pid = *((int *)param);
34 enqueue(queue, input[0]);
35 succ1 = dequeue(queue, &output[0]);
36 //printf("Dequeue: %d\n", output[0]);
39 enqueue(queue, input[1]);
40 succ2 = dequeue(queue, &output[1]);
44 int user_main(int argc, char **argv)
48 unsigned int in_sum = 0, out_sum = 0;
50 queue = (queue_t *)calloc(1, sizeof(*queue));
54 threads = (std::thread *)malloc(num_threads * sizeof(std::thread));
55 param = (int *)malloc(num_threads * sizeof(*param));
56 input = (unsigned *)calloc(num_threads, sizeof(*input));
57 output = (unsigned *)calloc(num_threads, sizeof(*output));
59 init_queue(queue, num_threads);
60 for (i = 0; i < num_threads; i++) {
62 //threads[i] = std::thread(main_task, ¶m[i]);
63 new (&threads[i])std::thread(main_task, ¶m[i]);
65 for (i = 0; i < num_threads; i++)
68 for (i = 0; i < num_threads; i++) {
72 for (i = 0; i < num_threads; i++)
73 printf("input[%d] = %u\n", i, input[i]);
74 for (i = 0; i < num_threads; i++)
75 printf("output[%d] = %u\n", i, output[i]);
77 MODEL_ASSERT(in_sum == out_sum);