#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);
}```
网友评论