naren_paste

multiprocessing_students

Jun 8th, 2024
364
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 0.80 KB | Source Code | 0 0
  1. import multiprocessing
  2.  
  3. def enroll_students(student_queue):
  4.     for student in ['Ajay', 'Bijay', 'Sanjay', 'Rizwan']:
  5.         student_queue.put(student)
  6.     student_queue.put(None)  # Sentinel value to signal the end of the queue
  7.  
  8. def register_students(student_queue):
  9.     while True:
  10.         enrollment_req = student_queue.get()
  11.         if enrollment_req is None:
  12.             break
  13.         print(f"register : {enrollment_req}")
  14.  
  15. if __name__ == '__main__':
  16.     student_queue = multiprocessing.Queue()
  17.  
  18.     enrollment_process = multiprocessing.Process(target=enroll_students, args=(student_queue,))
  19.     re_process = multiprocessing.Process(target=register_students, args=(student_queue,))
  20.  
  21.     enrollment_process.start()
  22.     re_process.start()
  23.  
  24.     enrollment_process.join()
  25.     re_process.join()
  26.  
Advertisement
Add Comment
Please, Sign In to add comment