Chia việc bằng Queue cho nhiều luồng có khoá

Mô tả bài toán

queue.Queue là cấu trúc an toàn với nhiều luồng: mỗi lần get_nowait() chỉ một luồng nhận được một phần tử nên không phần tử nào bị xử lý hai lần. Danh sách kết quả thì chưa an toàn, nên mọi lần ghi vào đó phải nằm trong threading.Lock. Kết quả cuối cùng được sắp xếp để không phụ thuộc thứ tự hoàn thành của các luồng.

Yêu cầu

Viết hàm consume_queue(items, worker_count=2):

• Ném ValueError nếu items rỗng hoặc worker_count nhỏ hơn 1.
• Đưa toàn bộ items vào một queue.Queue, rồi tạo worker_count luồng chạy cùng một

hàm xử lý.

• Mỗi luồng lặp: lấy một phần tử bằng get_nowait(); gặp queue.Empty thì kết thúc;

với mỗi phần tử lấy được, nhân nó với 10 rồi ghi vào danh sách chung bên trong vùng có khoá.

• Chờ mọi luồng kết thúc bằng join() rồi trả về danh sách kết quả đã sắp xếp tăng dần.

Quy ước nộp bài

Nộp hàm consume_queue trong solution.py. Hệ thống gọi hàm trực tiếp theo tên đối số và so danh sách trả về với kết quả soạn tay; không đọc dữ liệu từ stdin và không in ra stdout.

Ràng buộc

• Mỗi phần tử phải được xử lý đúng một lần: mỗi luồng phải lặp cho tới khi hàng đợi cạn.
• Mọi lần ghi vào danh sách chung phải nằm trong khoá.
• Trả về danh sách đã sắp xếp, không phụ thuộc luồng nào chạy xong trước.
• Không dùng sleep và không đo thời gian chạy.