Upload New File

Homeworks_2Semestr/ADTQueue_withMutex/main.c

+#include <pthread.h>
+#include "ADTQueue.h"
+
+queue* q;
+pthread_mutex_t m;
+
+void* getData(void* args)
+{
+    for (int i = 0; i < 5; i++)
+    {
+        push(q, (void*)i);
+    }
+    return NULL;
+}
+int main()
+{
+    q = init(1000, sizeof(int));
+    pthread_t first, second;
+    int id1 = 1, id2 = 2;
+
+    pthread_mutex_init(&m, NULL);
+    q->m = m;
+
+    pthread_create(&first, NULL, getData, &id1);
+    pthread_create(&second, NULL, getData, &id2);
+
+    pthread_join(first, NULL);
+    pthread_join(second, NULL);
+
+    pthread_mutex_destroy(&m);
+
+    pop(q);
+    iterate(q);
+    clean(q);
+
+    return 0;
+}