张家港杨舍网站制作,永兴网站开发,如何制作优秀的网页,腾飞网站建设线程概述 线程基本编程 函数说明
pthread_create(): 创建线程#xff0c;成功返回0pthread_exit(): 主动退出线程#xff0c;成功返回0pthread_join(): 挂起线程等待结束#xff0c;成功返回0pthread_cancel在别的线程中终止另一个线程的执行#xff0c;成功返回0 示例…线程概述 线程基本编程 函数说明
pthread_create(): 创建线程成功返回0pthread_exit(): 主动退出线程成功返回0pthread_join(): 挂起线程等待结束成功返回0pthread_cancel在别的线程中终止另一个线程的执行成功返回0 示例代码创建三个线程每个线程重用同一个执行每个线程五次循环每次循环随机等待1-10s。 /* thread.c */#include stdio.h
#include stdlib.h
#include pthread.h#define THREAD_NUMBER 3 /*宏定义线程数量*/
#define REPEAT_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 REPEAT_NUMBER; count){ delay_time (int)(rand() * DELAY_TIME_LEVELS/(RAND_MAX)) 1;sleep(delay_time);/*线程几工作 几 次 等待 几 秒*/printf(\tThread %d: job %d delay %d\n, thrd_num, count, delay_time);}printf(Thread %d finished\n, thrd_num);/*五次任务做完要输出线程几完成了*/pthread_exit(NULL);
}/*主函数*/
int main(void)
{/*结构体解释typedef unsigned long int pthread_t; 用途pthread_t用于声明线程ID。 sizeof(pthread_t) 4;*//*先赋值工作数*/pthread_t thread[THREAD_NUMBER];int no 0, res;void * thrd_ret;srand(time(NULL));/*time(NULL);就是返回从1970年元旦午夜0点到现在的秒数。 srand(time(NULL)); 是以当前时间为种子产生随意数。srand和rand()配合使用产生伪随机数序列。rand函数在产生随机数前需要系统提供的生成伪随机数序列的种子rand根据这个种子的值产生一系列随机数。如果系统提供的种子没有变化每次调用rand函数生成的伪随机数序列都是一样的。srand(unsigned seed)通过参数seed改变系统提供的种子值从而可以使得每次调用rand函数生成的伪随机数序列不同从而实现真正意义上的“随机”。通常可以利用系统时间来改变系统的种子值即srand(time(NULL))可以为rand函数提供不同的种子值进而产生不同的随机数序列 *//*循环创建三个线程*/for (no 0; no THREAD_NUMBER; no){res pthread_create(thread[no], NULL, thrd_func, (void*)no);/*thread[no]线程标识符表示线程的标号NULL线程属性通常取NULL thrd_func线程处理函数(void*)no传递给线程处理函数的参数函数成功执行返回0出错返回错误码pthread_create()函数作用创建一个线程并指定线程处理函数thrd_func从而执行该函数规定的动作*/if (res ! 0){printf(Create thread %d failed\n, no);/*pthread_create失败返回0*/exit(res);}}printf(Create threads successWaiting for threads to running..\n);/*成功输出这句*//*循环挂起线程*/for (no 0; no THREAD_NUMBER; no){res pthread_join(thread[no], thrd_ret); //thrd_ret用户定义的指针用来存储被等待线程结束时返回值/*pthread_join使一个线程等待另一个线程结束。 代码中如果没有pthread_join主线程会很快结束从而使整个进程结束从而使创建的线程没有机会开始执行就结束了。加入pthread_join后主线程会一直等待直到等待的线程结束自己才结束使创建的线程有机会执行。该函数作用当thread[no]尚未运行结束时调用pthread_join()的主进程阻塞直到thread[no]线程退出该线程所占据的资源才被释放主进程才能结束主进程等待线程运行结束后pthread_join函数返回0该线程资源释放如果出错返回错误码*/if (!res){printf(Thread %d joined\n, no);/*该语句打印出来代表thread[no]已经结束运行释放其占据的资源*/}else{printf(Thread %d join failed\n, no);}}return 0;
}
线程之间的同步互斥 信号量适用于同时可用的资源是多个 互斥锁适用于同时可用的资源唯一
互斥锁线程控制 互斥锁基本函数 互斥锁初始化pthread_muttex_init互斥锁上锁 pthread_muttex_lock互斥锁判断上锁pthread_muttex_trylock()互斥锁解锁pthread_muttex_unlock消除互斥锁pthread_muttex_destroy 示例代码是在上一个示例基础上增加了互斥锁的功能 /* thread_mutex.c */
#include stdio.h
#include stdlib.h
#include pthread.h
#define THREAD_NUMBER 3 /*有三个线程*/
#define REPEAT_NUMBER 3 /*每个线程三个任务*/
#define DELAY_TIME_LEVELS 10.0 /*每个线程任务随机等待1-10s*/
pthread_mutex_t mutex;/**/
void * thrd_func(void *arg)
{int thrd_num (int)arg;int delay_time 0, count 0;int res;res pthread_mutex_lock(mutex); /*上互斥锁成功返回0非0值代表失败并返回出错信息*/ if (res){/*上锁失败*/printf(Thread %d lock failed\n, thrd_num); pthread_exit(NULL);}/*上锁成功输出一句线程开始*/ printf(Thread %d is starting\n, thrd_num);/*三次任务*/for (count 0; count REPEAT_NUMBER; count){ delay_time (int)(rand() * DELAY_TIME_LEVELS/(RAND_MAX)) 1;sleep(delay_time);printf(\tThread %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));/*互斥锁初始化*/pthread_mutex_init(mutex, NULL);/*参数解释mutex创建互斥锁都这么写NULL表示创建的是快速互斥锁调用线程会阻塞直至拥有互斥锁的线程解锁为止知道有这么回事就好 *//*循环创建三个线程*/for (no 0; no THREAD_NUMBER; no){/*线程号默认NULL线程处理函数传递参数*/res pthread_create(thread[no], NULL, thrd_func, (void*)no);if (res ! 0){printf(Create thread %d failed\n, no);/*报错*/exit(res);}}printf(Create threads 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 joined\n, no); }else{ printf(Thread %d join failed\n, no); }pthread_mutex_unlock(mutex);/*解开互斥锁*/ } pthread_mutex_destroy(mutex); /*消除删除互斥锁*/return 0;
} 信号量线程控制 互斥锁是一种特殊的信号量互斥锁初始值为1信号量初始值为0
