- pthread_mq_send_generic(&myq, "AHOJ1", false, true, NULL);
- pthread_mq_send_generic(&myq, "AHOJ2", false, true, NULL);
- pthread_mq_send_generic(&myq, "AHOJ3", true, true, NULL);
- pthread_mq_send_generic(&myq, "AHOJ4", true, true, NULL);
- pthread_mq_send_generic(&myq, "AHOJ5", false, true, NULL);
- //pthread_mq_send_generic(&myq, "AHOJ6", false, true, NULL);
-
- for(int i = 0; i<5; i++) {
- printf("%.6s\n", (char *)(myq.data+i*6));
+
+ pthread_t t;
+ pthread_create(&t, NULL, thread_recv, NULL);
+
+ pthread_mq_send_generic(&myq, "AHOJ1", false, NULL);
+ pthread_mq_send_generic(&myq, "AHOJ2", false, NULL);
+ pthread_mq_send_generic(&myq, "AHOJ3", true, NULL);
+ pthread_mq_send_generic(&myq, "AHOJ4", true, NULL);
+ pthread_mq_send_generic(&myq, "AHOJ5", false, NULL);
+ pthread_mq_send_generic(&myq, "AHOJ6", true, NULL);
+
+ while(1) {
+ pthread_mq_send_generic(&myq, "B", false, NULL);
+ pthread_mq_send_generic(&myq, "A", true, NULL);
+ pthread_mq_send_generic(&myq, " A", false, NULL);
+ pthread_mq_send_generic(&myq, " B", false, NULL);