ThreadBlockingQueue có chèn và loại bỏ các phương thức an toàn không?

Question

Tôi đang sử dụng LinkedBlockingQueue giữa hai chủ đề khác nhau. Một chuỗi thêm dữ liệu qua add, trong khi luồng khác nhận dữ liệu qua take.

Câu hỏi của tôi là, tôi có cần phải đồng bộ hóa quyền truy cập vào add và take. Có phải chuỗi chèn và loại bỏ phương thức an toàn của LinkedBlockingQueue không?

Answer 1

Có. Từ the docs:..

"BlockingQueue triển khai là thread-safe Tất cả các phương pháp xếp hàng đạt được tác động của chúng nguyên tử sử dụng khóa nội bộ hoặc các hình thức kiểm soát đồng thời Tuy nhiên, phần lớn Bộ sưu tập các hoạt động addAll, containsAll, retainAll và removeAll không nhất thiết phải được thực hiện một cách nguyên tắc trừ khi được chỉ định khác trong khi triển khai.chỉ thêm một số thành phần trong c. "

Answer 2

Vâng, BlockingQueue phương pháp add() và take() được an toàn nhưng với một sự khác biệt chủ đề.

add() và take() phương pháp sử dụng 2 đối tượng ReentrantLock khác nhau.

add() phương pháp sử dụng

private final ReentrantLock putLock = new ReentrantLock(); 

take() phương pháp sử dụng

private final ReentrantLock takeLock = new ReentrantLock(); 

Do đó, truy cập đồng thời để add() phương pháp được đồng bộ. Tương tự, truy cập đồng thời vào phương thức take() là synchronized.

Nhưng, truy cập đồng thời để add() và take() phương pháp không phải là synchronized kể từ khi họ đang sử dụng 2 đối tượng khóa khác nhau (ngoại trừ trong điều kiện cạnh của hàng đợi đầy đủ/trống).

Answer 3

Đơn giản chỉ cần có, chủ đề chắc chắn của nó an toàn nếu không nó sẽ không đủ điều kiện làm ứng cử viên để lưu trữ phần tử cho ThreadPoolExecutor.

Chỉ cần thêm và truy xuất phần tử mà không phải lo lắng về đồng thời cho BlockingQueue.