pthread_mutex_trylock()

  1 #include <pthread.h>
  2 #include <stdio.h>
  3 #include <unistd.h>
  4 #include <stdlib.h>
  5 #include <time.h>
  6 #include <string.h>
  7 #include <errno.h>
  8 
  9 pthread_mutex_t my_sync;
 10 pthread_t kidA,kidB;
 11     int anykey;
 12 
 13 int lab_pthread_mutex_trylock(pthread_mutex_t *mutex)
 14 {
 15 int ret;
 16 ret=pthread_mutex_destroy(mutex);
 17 printf("\n\nRET:%d\n\n",ret);
 18 if (ret==0)
 19  {
 20  printf("Mutex is free!");
 21  pthread_mutex_init (mutex, NULL);
 22  return 0;
 23  }
 24 else if (ret==EBUSY)
 25  {
 26  printf("Mutex is busy.");
 27  return 1;
 28  }
 29 else
 30  {
 31  perror("mutex:");
 32  return -1;
 33  }
 34 }
 35 
 36 int lab_pthread_cond_timedwait(pthread_cond_t *cond,pthread_mutex_t *mutex,     unsigned int timetowait) // это должно стать еще одной функцией
 37 {
 38 
 39 }
 40 
 41 
 42 void * streamA () //Поток А
 43 {
 44     for (;;)
 45     {
 46         sleep(1);
 47         printf("----------\nThread A tries to lock MUTEX...\n");
 48         pthread_mutex_lock (&my_sync);
 49         printf("Thread A locks MUTEX\n");
 50         sleep (1.5);
 51         printf("Thread A keeps locking MUTEX\n");
 52         pthread_mutex_unlock (&my_sync);
 53         printf("Thread A unlocks MUTEX\n*******\n");
 54     }
 55 }
 56 
57 void * streamB () // Поток B
 58 {
 59     for (;;)
 60     {
 61         sleep(3);
 62         printf("Thread B tries to lock MUTEX\n");
 63         anykey=lab_pthread_mutex_trylock (&my_sync);
 64         if (anykey==0)
 65           printf("Thread B can lock MUTEX. Returned:%d\n",anykey);
 66         else if (anykey==1)
 67           printf("Thread B will be locked! Returned:%d\n",anykey);
 68         else if (anykey==-1)
 69           printf("Error! Returned:%d\n",anykey);
 70         printf("Thread B ends.\n");
 71         pthread_mutex_unlock (&my_sync);
 72     }
 73 }
 74 
 75 int main()
 76 {
 77     pthread_attr_t attr;
 78     pthread_mutex_init (&my_sync, NULL);
 79     pthread_attr_init(&attr);
 80     pthread_create (&kidA, &attr, streamA, NULL);
 81     pthread_create (&kidB, &attr, streamB, NULL);
 82     pthread_join(kidA,NULL);
 83     pthread_join(kidB,NULL);
 84 }