output/mpmc-queue/testcase2.cc

   1 #include <inttypes.h>
   2 #include <threads.h>
   3 #include <stdio.h>
   4 #include <unistd.h>
   5 #include <stdlib.h>
   6
   7 #include <librace.h>
   8
   9 #include "mpmc-queue.h"
  10
  11 void threadA(struct mpmc_boundq_1_alt<int32_t, 1> *queue)
  12 {
  13         int32_t *bin;
  14
  15
  16         for (int i = 0; i < 1; i++) {
  17                 bin = queue->write_prepare();
  18                 if (bin) {
  19                         *bin = 1;
  20                         queue->write_publish(bin);
  21                         printf("write_bin %d, val %d\n", bin, 1);
  22                 } else {
  23                         printf("write failed\n");
  24                 }
  25
  26                 bin = queue->read_fetch();
  27                 if (bin) {
  28                         printf("read_bin: %d, val %d\n", bin, *bin);
  29                         queue->read_consume(bin);
  30                 } else {
  31                         printf("read failed\n");
  32                 }
  33         }
  34
  35 }
  36
  37 void threadB(struct mpmc_boundq_1_alt<int32_t, 1> *queue)
  38 {
  39         int32_t *bin;
  40         for (int i = 0; i < 1; i++) {
  41                 bin = queue->read_fetch();
  42                 if (bin) {
  43                         printf("read_bin: %d, val %d\n", bin, *bin);
  44                         queue->read_consume(bin);
  45                 } else {
  46                         printf("read failed\n");
  47                 }
  48         }
  49
  50
  51 }
  52
  53 int user_main(int argc, char **argv)
  54 {
  55         struct mpmc_boundq_1_alt<int32_t, 1> queue;
  56         thrd_t A, A1, B;
  57
  58         printf("Adding initial element\n");
  59         int32_t *bin;
  60         for (int i = 0; i < 1; i++) {
  61                 printf("#%d, \n", i);
  62                 bin = queue.write_prepare();
  63                 *bin = 17;
  64                 printf("init_write_bin %d, val %d\n", bin, 17);
  65                 queue.write_publish(bin);
  66
  67                 bin = queue.read_fetch();
  68                 if (bin) {
  69                         printf("init_read: %d, val %d\n", bin, *bin);
  70                         queue.read_consume(bin);
  71                 }
  72         }
  73
  74         for (int i = 0; i < 3; i++) {
  75
  76         }
  77
  78         printf("Start threads\n");
  79
  80         thrd_create(&A, (thrd_start_t)&threadA, &queue);
  81         thrd_create(&A1, (thrd_start_t)&threadA, &queue);
  82         thrd_create(&B, (thrd_start_t)&threadB, &queue);
  83
  84         thrd_join(A);
  85         thrd_join(A1);
  86         thrd_join(B);
  87         printf("Threads complete\n");
  88
  89         return 0;
  90 }
  91