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)
30 std::this_thread::sleep_for(std::chrono::milliseconds(10));
32 int pid = *((int *)param);
35 enqueue(queue, input[0]);
36 succ1 = dequeue(queue, &output[0]);
37 //printf("Dequeue: %d\n", output[0]);
40 enqueue(queue, input[1]);
41 succ2 = dequeue(queue, &output[1]);
45 int user_main(int argc, char **argv)
49 unsigned int in_sum = 0, out_sum = 0;
51 queue = (queue_t *)calloc(1, sizeof(*queue));
55 threads = (std::thread *)malloc(num_threads * sizeof(std::thread));
56 param = (int *)malloc(num_threads * sizeof(*param));
57 input = (unsigned *)calloc(num_threads, sizeof(*input));
58 output = (unsigned *)calloc(num_threads, sizeof(*output));
60 init_queue(queue, num_threads);
61 for (i = 0; i < num_threads; i++) {
63 //threads[i] = std::thread(main_task, ¶m[i]);
64 new (&threads[i])std::thread(main_task, ¶m[i]);
66 for (i = 0; i < num_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]);
78 MODEL_ASSERT(in_sum == out_sum);