死锁

2018-05-03  本文已影响0人  焦迈奇
#include <stdio.h>
#include <sys/types.h>
#include <unistd.h>
#include <ctype.h>
#include <pthread.h>

#define MAX_THREAD 3 
unsigned long long main_counter, counter[MAX_THREAD];
void* thread_worker(void*);
pthread_mutex_t mutext = PTHREAD_MUTEX_INITIALIZER;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
int main(int argc,char *argv[])
{
    int i, ch;
    int num[3];
    pthread_t pthread_id[MAX_THREAD] = {0},thid; 
    //int *arr;
    for (i=0; i<MAX_THREAD; i++)
    {

       /* arr=(int *)malloc(sizeof(int));
        *arr=i;*/
    num[i] = i;
        if(pthread_create(&thid,NULL,(void*)thread_worker,&num[i])==0)
    {        
            pthread_id[i]=thid;
    }
    else
    {
        printf("thread creater failed!\n");
    }
    }
    pthread_mutex_lock(&mutex);
    do
    {
        //char t;
        unsigned long long sum = 0; 
        for (i=0; i<MAX_THREAD; i++)
        {
            sum += counter[i];
            printf("%d %llu ",i, counter[i]);
        }
        printf("\n\n%llu\n%llu\n\n", main_counter, sum);
    }while ((ch = getchar()) != 'q');
    //return 0;
      pthread_mutex_unlock(&mutex);
        pthread_mutex_destroy(&mutex);
        pthread_mutex_destroy(&mutex);
        return 0;
    
}
void* thread_worker(void* p)
{
    int thread_num;
   thread_num=*(int*)p;

    for(;;)
    { 
      pthread_mutex_lock(&mutext);
    main_counter++;
     counter[thread_num]++; 
     //main_counter++;
    sleep(1); 
     pthread_mutex_unlock(&mutext);
    }
    return NULL;
}
#include <sys/types.h>
#include <unistd.h> 
#include <ctype.h>
#include <pthread.h> 
#define LOOP_TIMES 10000 
pthread_mutex_t mutex1 = PTHREAD_MUTEX_INITIALIZER;
pthread_mutex_t mutex2 = PTHREAD_MUTEX_INITIALIZER;
void* thread_worker(void*);
void critical_section(int thread_num, int i); 
void  main(void)
{ 
    int rtn, i; 
    pthread_t pthread_id = 0; 
    rtn = pthread_create(&pthread_id, NULL, thread_worker, NULL ); 
    if(rtn != 0)
    { 
        printf("pthread_create ERROR!\n"); 
        return -1; 

    } 
    for (i=0; i<LOOP_TIMES; i++)
    { 
        pthread_mutex_lock(&mutex1);
        pthread_mutex_lock(&mutex2); 
        critical_section(1, i); 
        pthread_mutex_unlock(&mutex2);
        pthread_mutex_unlock(&mutex1);

    } 
    pthread_mutex_destroy(&mutex1);
    pthread_mutex_destroy(&mutex2); 
        //return 0; 
} 
void* thread_worker(void* p)
{ 
    int i; 
    for (i=0; i<LOOP_TIMES; i++)
    { 
        pthread_mutex_lock(&mutex1);
        pthread_mutex_lock(&mutex2); 
         critical_section(2, i); 
        pthread_mutex_unlock(&mutex2);
        pthread_mutex_unlock(&mutex1);
    }
} 
void critical_section(int thread_num, int i)
{ 
    printf("Thread%d:%d\n", thread_num, i);
}```
上一篇 下一篇

猜你喜欢

热点阅读