/*thread.c*/
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#define THREAD_NUMBER 3 /*线程数*/
#define REPEAY_NUMBER 5 /*每个线程中的小任务*/
#define DELAY_TIME_LEVELS 10.0 /*小任务之间的最大时间间隔*/
void *thrd_func(void *arg)
{/*线程函数例程*/
int thrd_num = (int)arg;
int delay_time = 0;
int count = 0;
printf("Thread %d is starting \n",thrd_num);
for(count = 0;count< REPEAY_NUMBER;count++)
{
delay_time = (int) (rand() * DELAY_TIME_LEVELS/(RAND_MAX))+1;
sleep(delay_time);
printf("\t Thread %d: job %d delay = %d\n",thrd_num,count,delay_time);
}
printf("Thread %d finished \n",thrd_num);
pthread_exit(NULL);
}
int main(void)
{
pthread_t thread[THREAD_NUMBER];
int no = 0,res;
void * thrd_ret;
srand(time(NULL));
for(no =0;no < THREAD_NUMBER; no ++)
{
/*创建多线程*/
res = pthread_create(&thread[no],NULL,thrd_func,(void*)no);
if(res != 0)
{
printf("Create thread %d failed \n",no);
}
}
printf("Create tread success\n Waiting for threads to finish...\n");
for(no = 0;no <THREAD_NUMBER;no++)
{
/*等待线程结束*/
res = pthread_join(thread[no],&thrd_ret);
if(!res)
{
printf("Thread %d jioned \n",no);
}
else
{
printf("Thread %d jion failed \n",no);
}
}
return 0;
}
本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系我们删除。