Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import multiprocessing
- def enroll_students(student_queue):
- for student in ['Ajay', 'Bijay', 'Sanjay', 'Rizwan']:
- student_queue.put(student)
- student_queue.put(None) # Sentinel value to signal the end of the queue
- def register_students(student_queue):
- while True:
- enrollment_req = student_queue.get()
- if enrollment_req is None:
- break
- print(f"register : {enrollment_req}")
- if __name__ == '__main__':
- student_queue = multiprocessing.Queue()
- enrollment_process = multiprocessing.Process(target=enroll_students, args=(student_queue,))
- re_process = multiprocessing.Process(target=register_students, args=(student_queue,))
- enrollment_process.start()
- re_process.start()
- enrollment_process.join()
- re_process.join()
Advertisement
Add Comment
Please, Sign In to add comment