共享存储系统编程课件.ppt

线程调用—线程管理 POSIX Solaris 2 pthread_create thr_create pthread_exit thr_exit pthread_kill thr_kill pthread_join thr_join pthread_self thr_self 线程调用—线程同步和互斥 POSIX Solaris 2 pthread_mutex_init mutex_init pthread_ mutex_destroy mutex_destroy pthread_ mutex_lock mutex_lock pthread_ mutex_trylock mutex_trylock pthread_ mutex_unlock mutex_unlock pthread_cond_init pthread_cond_destroy pthread_cond_wait pthread_cond_timedwait pthread_cond_signal pthread_cond_broadcast Pthreads实现计算?的实例 1 Pthreads实现计算?的实例 2 对生产者驱动的有界缓冲区问题的Pthread条件变量解 void *producer(void *arg1){ int i; for (i=1;i=SUMSIZE;i++){ pthread_mutex_lock(slot_lock); while(nslots=0) pthread_cond_wait(slots,slot_lock); nslots--; pthread_mutex_unlock(slot_lock); put_item(i*i); pthread_mutex_lock(item_lock); nitems++; pthread_cond_signal(items); pthread_mutex_unlock(item_lock); } pthread_mutex_lock(item_lock); producer_done=1; pthread_cond_broadcast(items); pthread_mutex_unlock(item_lock); return NULL;} void *consumer(void *arg2){ int i,myitem; for (;;){ pthread_mutex_lock(item_lock); while ((nitems=0)!producer_done) pthread_cond_wait(items,item_lock); if ((nitems=0)producer_done){ ptherad_mutex_unlock(item_lock); break; } nitems--; pthread_mutex_unlock(item_lock); get_item(myitem); sum+=myitem; pthread_mutex_lock(slot_lock nslots++; cond_signal(slots); pthread_mutex_unlock(slot_lock); } return NULL; } 共享存储系统编程 13.1 ANSI X3H5共享存储模型 13.2 POSIX 线程模型 13.3 OpenMP模型 The History of OpenMP What is directive/pragma? Directive-based general purpose parallel programming API with emphasis on the ability to parallelize existing serial programs Why a new standard? Who’s Involved? Parallelism model and basic directives Fortran77, Fortran90 C, C++ OpenMP标准 The History of OpenMP A key intermediate step was X3H5 in the late 80