2025年经典进程PV例题(带答案)

2025年经典进程PV例题(带答案)1.生产者-消费者问题问题描述生产者-消费者问题是一个经典的进程同步问题，有一组生产者进程和一组消费者进程共享一个初始为空、大小为n的缓冲区。生产者的工作是制造数据并将其放入缓冲区，消费者的工作是从缓冲区中取出数据并使用。需要保证生产者不会在缓冲区满时放入数据，消费者不会在缓冲区空时取出数据，同时要避免多个生产者或消费者同时访问缓冲区导致数据不一致的问题。代码实现```pythonimportthreadingimporttime缓冲区大小BUFFER_SIZE=5缓冲区buffer=[]信号量mutex=threading.Semaphore(1)互斥信号量，用于保护缓冲区的访问empty=threading.Semaphore(BUFFER_SIZE)表示缓冲区中空槽的数量full=threading.Semaphore(0)表示缓冲区中满槽的数量生产者线程函数defproducer():globalbufferwhileTrue:empty.acquire()等待缓冲区有空槽mutex.acquire()进入临界区item=time.time()生产一个数据项buffer.append(item)print(f"Produced{item}")mutex.release()离开临界区full.release()通知缓冲区有新的数据项time.sleep(1)消费者线程函数defconsumer():globalbufferwhileTrue:full.acquire()等待缓冲区有满槽mutex.acquire()进入临界区item=buffer.pop(0)print(f"Consumed{item}")mutex.release()离开临界区empty.release()通知缓冲区有一个空槽time.sleep(1)创建生产者和消费者线程producer_thread=threading.Thread(target=producer)consumer_thread=threading.Thread(target=consumer)启动线程producer_thread.start()consumer_thread.start()等待线程结束（这里不会结束，因为是无限循环）producer_thread.join()consumer_thread.join()```答案解释-`mutex`信号量用于保证同一时间只有一个线程（生产者或消费者）可以访问缓冲区，防止多个线程同时修改缓冲区导致数据不一致。-`empty`信号量表示缓冲区中空槽的数量，生产者在生产数据前需要先获取一个空槽，即调用`empty.acquire()`。-`full`信号量表示缓冲区中满槽的数量，消费者在消费数据前需要先获取一个满槽，即调用`full.acquire()`。2.读者-写者问题问题描述读者-写者问题是指有多个读者和多个写者共享一个数据对象，允许多个读者同时访问该数据对象，但不允许写者和其他写者或读者同时访问该数据对象。也就是说，写操作是排他的，而读操作可以并发进行。代码实现```pythonimportthreading信号量mutex=threading.Semaphore(1)用于保护对read_count的访问wrt=threading.Semaphore(1)用于保护对共享数据的写操作read_count=0记录当前读者的数量读者线程函数defreader():globalread_countwhileTrue:mutex.acquire()进入临界区，保护read_countread_count+=1ifread_count==1:wrt.acquire()如果是第一个读者，阻止写者访问mutex.release()离开临界区模拟读操作print("Reading...")mutex.acquire()进入临界区，保护read_countread_count-=1ifread_count==0:wrt.release()如果是最后一个读者，允许写者访问mutex.release()离开临界区写者线程函数defwriter():whileTrue:wrt.acquire()进入临界区，阻止其他写者和读者访问模拟写操作print("Writing...")wrt.release()离开临界区创建读者和写者线程reader_threads=[threading.Thread(target=reader)for_inrange(3)]writer_threads=[threading.Thread(target=writer)for_inrange(2)]启动线程forthreadinreader_threads:thread.start()forthreadinwriter_threads:thread.start()等待线程结束（这里不会结束，因为是无限循环）forthreadinreader_threads:thread.join()forthreadinwriter_threads:thread.join()```答案解释-`mutex`信号量用于保护对`read_count`的访问，确保多个读者线程对`read_count`的修改不会冲突。-`wrt`信号量用于保护对共享数据的写操作，当有写者访问时，其他写者和读者都不能访问。-`read_count`记录当前读者的数量，当第一个读者进入时，会获取`wrt`信号量，阻止写者访问；当最后一个读者离开时，会释放`wrt`信号量，允许写者访问。3.哲学家进餐问题问题描述哲学家进餐问题描述了有五个哲学家围坐在一张圆桌旁，每两个哲学家之间有一根筷子，一共五根筷子。哲学家的行为是思考和进餐，进餐时需要同时拿起左右两根筷子，思考时则放下筷子。问题的关键是要避免死锁和饥饿现象的发生。代码实现```pythonimportthreadingimporttime筷子信号量chopsticks=[threading.Semaphore(1)for_inrange(5)]哲学家线程函数defphilosopher(id):whileTrue:print(f"Philosopher{id}isthinking...")time.sleep(1)尝试拿起筷子left_chopstick=idright_chopstick=(id+1)%5避免死锁，奇数号哲学家先拿左边筷子，偶数号哲学家先拿右边筷子ifid%2==0:chopsticks[right_chopstick].acquire()chopsticks[left_chopstick].acquire()else:chopsticks[left_chopstick].acquire()chopsticks[right_chopstick].acquire()print(f"Philosopher{id}iseating...")time.sleep(1)放下筷子chopsticks[left_chopstick].release()chopsticks[right_chopstick].release()创建哲学家线程philosopher_threads=[threading.Thread(target=philosopher,args=(i,))foriinrange(5)]启动线程forthreadinphilosopher_threads:thread.start()等待线程结束（这里不会结束，因为是无限循环）forthreadinphilosopher_threads:thread.join()```答案解释-每个筷子用一个信号量表示，初始值为1，表示筷子可用。-为了避免死锁，奇数号哲学家先拿左边的筷子，偶数号哲学家先拿右边的筷子。这样可以打破循环等待的条件，从而避免死锁的发生。4.理发师睡觉问题问题描述理发店有一位理发师、一把理发椅和n把供顾客等待的椅子。如果没有顾客，理发师就坐在理发椅上睡觉。当一个顾客到来时，如果所有的椅子都有人坐，顾客就会离开；如果有空椅子，顾客会坐在其中一把空椅子上等待。如果理发师在睡觉，顾客会叫醒他。代码实现```pythonimportthreadingimporttime信号量customers=threading.Semaphore(0)等待的顾客数量barber=threading.Semaphore(0)理发师是否空闲mutex=threading.Semaphore(1)互斥信号量，用于保护waiting_customers的访问waiting_customers=0等待的顾客数量MAX_CUSTOMERS=5最大等待顾客数量理发师线程函数defbarber_thread():globalwaiting_customerswhileTrue:customers.acquire()等待顾客mutex.acquire()进入临界区waiting_customers-=1顾客离开等待队列barber.release()理发师开始工作mutex.release()离开临界区模拟理发过程print("Barberiscuttinghair...")time.sleep(2)顾客线程函数defcustomer_thread():globalwaiting_customersmutex.acquire()进入临界区ifwaiting_customers<MAX_CUSTOMERS:waiting_customers+=1顾客进入等待队列print("Customerenteredandiswaiting.")customers.release()通知理发师有顾客mutex.release()离开临界区barber.acquire()等待理发师print("Customerisgettingahaircut.")else:print("Noemptychairs,customerleft.")mutex.release()离开临界区创建理发师线程barber_t=threading.Thread(target=barber_thread)barber_t.start()创建多个顾客线程customer_threads=[threading.Thread(target=customer_thread)for_inrange(10)]forthreadincustomer_threads:thread.start()等待线程结束（这里不会结束，因为理发师线程是无限循环）barber_t.join()forthreadincustomer_threads:thread.join()```答案解释-`customers`信号量表示等待的顾客数量，理发师通过`customers.acquire()`等待顾客。-`barber`信号量表示理发师是否空闲，顾客通过`barber.acquire()`等待理发师。-`mutex`信号量用于保护`waiting_customers`的访问，确保多个顾客线程对`waiting_customers`的修改不会冲突。5.吸烟者问题问题描述有三个吸烟者和一个供应者。每个吸烟者不断地卷烟并抽掉它，但要卷起并抽掉一支烟，需要三种材料：烟草、纸和火柴。三个吸烟者中，第一个有烟草，第二个有纸，第三个有火柴。供应者会随机地将两种材料放在桌子上，拥有剩下那种材料的吸烟者会拿起桌子上的材料，卷一根烟并抽掉它，然后给供应者一个信号，供应者会再放另外两种材料在桌子上。代码实现```pythonimportthreadingimporttimeimportrandom信号量agent=threading.Semaphore(1)供应者信号量tobacco_and_paper=threading.Semaphore(0)烟草和纸的信号量tobacco_and_matches=threading.Semaphore(0)烟草和火柴的信号量paper_and_matches=threading.Semaphore(0)纸和火柴的信号量finished=threading.Semaphore(0)吸烟者抽完烟的信号量供应者线程函数defagent_thread():whileTrue:agent.acquire()供应者开始工作choice=random.randint(1,3)ifchoice==1:tobacco_and_paper.release()提供烟草和纸print("Agentprovidedtobaccoandpaper.")elifchoice==2:tobacco_and_matches.release()提供烟草和火柴print("Agentprovidedtobaccoandmatches.")else:paper_and_matches.release()提供纸和火柴print("Agentprovidedpaperandmatches.")finished.acquire()等待吸烟者抽完烟有火柴的吸烟者线程函数defsmoker_with_matches():whileTrue:tobacco_and_paper.acquire()等待烟草和纸print("Smokerwithmatchesissmoking...")time.sleep(2)finished.release()通知供应者抽完烟agent.release()允许供应者继续工作有纸的吸烟者线程函数defsmoker_with_paper():whileTrue:tobacco_and_matches.acquire()等待烟草和火柴print("Smokerwithpaperissmoking...")time.sleep(2)finished.release()通知供应者抽完烟agent.release()允许供应者继续工作有烟草的吸烟者线程函数defsmoker_with_tobacco():