Làm thế nào để loại bỏ các yếu tố từ một hàng đợi trong Java với một vòng lặp

Question

Tôi có một cấu trúc dữ liệu như thế này:

mailbox BlockingQueue = new LinkedBlockingQueue();

Tôi đang cố gắng để làm điều này:

for(Mail mail: mailbox) 
{ 
    if(badNews(mail)) 
    { 
     mailbox.remove(mail); 
    } 
} 

Rõ ràng các nội dung của vòng can thiệp với các giới hạn và một lỗi được kích hoạt, vì vậy tôi thường làm điều này:

for(int i = 0; i < mailbox.size(); i++) 
{ 
    if(badNews(mailbox.get(i))) 
    { 
     mailbox.remove(i); 
     i--; 
    } 
} 

Nhưng đáng buồn là BlockingQueue không có chức năng lấy hoặc xóa một phần tử theo chỉ mục, vì vậy tôi bị kẹt. Ý tưởng nào?

Chỉnh sửa - Một số giải thích rõ ràng: Một trong những mục tiêu của tôi là duy trì cùng một thứ tự như vậy xuất hiện từ đầu và đưa nó trở lại vào đuôi là không tốt. Ngoài ra, mặc dù không có chủ đề nào khác sẽ xóa thư khỏi hộp thư, chúng sẽ thêm vào thư, vì vậy tôi không muốn ở giữa thuật toán xóa, nhờ ai đó gửi thư cho tôi và sau đó có ngoại lệ.

Cảm ơn trước!

Answer 1

Bạn có thể p̶o̶p̶ poll và p̶u̶s̶h̶ offer tất cả các phần tử trong hàng đợi cho đến khi bạn tạo vòng lặp hoàn chỉnh trên hàng đợi của mình. Dưới đây là ví dụ:

Mail firstMail = mailbox.peek(); 
Mail currentMail = mailbox.pop(); 
while (true) { 
    //a base condition to stop the loop 
    Mail tempMail = mailbox.peek(); 
    if (tempMail == null || tempMail.equals(firstMail)) { 
     mailbox.offer(currentMail); 
     break; 
    } 
    //if there's nothing wrong with the current mail, then re add to mailbox 
    if (!badNews(currentMail)) { 
     mailbox.offer(currentMail); 
    } 
    currentMail = mailbox.poll(); 
} 

Lưu ý rằng phương pháp này sẽ chỉ hoạt động nếu mã này được thực thi trong một chuỗi và không có chuỗi nào khác xóa mục khỏi hàng đợi này.

Có thể bạn cần kiểm tra xem bạn có thực sự muốn thăm dò ý kiến ​​hoặc lấy các yếu tố từ BlockingQueue hay không. Tương tự cho cung cấp và đặt. Thông tin

thêm:

• Java BlockingQueue take() vs poll()
• LinkedBlockingQueue put vs offer

---

Một cách tiếp cận ít lỗi đang sử dụng một bộ sưu tập tạm thời, không nhất thiết đồng thời, và lưu trữ các yếu tố bạn vẫn cần trong xếp hàng. Dưới đây là ví dụ về khởi động:

List<Mail> mailListTemp = new ArrayList<>(); 
while (mailbox.peek() != null) { 
    Mail mail = mailbox.take(); 
    if (!badNews(mail)) { 
     mailListTemp.add(mail); 
    } 
} 
for (Mail mail : mailListTemp) { 
    mailbox.offer(mail); 
} 

Answer 2

Tôi đã xem xét các giải pháp được đăng và tôi nghĩ rằng tôi đã tìm thấy một phiên bản phục vụ mục đích của mình. Bạn nghĩ gì về cái này?

int size = mailbox.size(); 
for(int i = 0; i < size; i++) 
{ 
    Mail currentMail = mailbox.poll(); 
    if (!badNews(currentMail)) 
     mailbox.offer(currentMail); 
} 

Chỉnh sửa: Giải pháp mới có thể không có sự cố. Các bạn nghĩ sao?

while(true) 
{ 
    boolean badNewRemains = false; 

    for(Mail mail: mailbox) 
    { 
     if(badNews(mail)) 
     { 
      badNewRemains = true; 
      mailbox.remove(mail); 
      break; 
     } 
    } 

    if(!badNewRemains) 
     break; 
} 

Answer 3

Bạn có thể dễ dàng triển khai hàng đợi cho nhu cầu của mình. Và bạn sẽ cần, nếu API được cung cấp không có các tính năng như vậy.

Một như:

import java.util.Iterator; 
import java.util.LinkedList; 


class Mail { 
    boolean badMail; 
} 

class MailQueue { 
    private LinkedList<Mail> backingQueue = new LinkedList<>(); 
    private final Object lock = new Object(); 

    public void push(Mail mail){ 
     synchronized (lock) { 
      backingQueue.addLast(mail); 
      if(backingQueue.size() == 1){ 
       // this is only element in queue, i.e. queue was empty before, so invoke if any thread waiting for mails in queue. 
       lock.notify(); 
      } 
     } 
    } 

    public Mail pop() throws InterruptedException{ 
     synchronized (lock) { 
      while(backingQueue.isEmpty()){ 
       // no elements in queue, wait. 
       lock.wait(); 
      } 
      return backingQueue.removeFirst(); 
     } 
    } 

    public boolean removeBadMailsInstantly() { 
     synchronized (lock) { 
      boolean removed = false; 
      Iterator<Mail> iterator = backingQueue.iterator(); 

      while(iterator.hasNext()){ 
       Mail mail = iterator.next(); 
       if(mail.badMail){ 
        iterator.remove(); 
        removed = true; 
       } 
      } 

      return removed; 
     } 
    } 
} 

Hàng đợi thực hiện sẽ được thread-safe, cho dù push hoặc pop. Ngoài ra, bạn có thể chỉnh sửa hàng đợi cho nhiều hoạt động hơn. Và nó sẽ cho phép truy cập phương thức removeBadMailsInstantly theo nhiều luồng (thread-safe). Và bạn cũng sẽ học các khái niệm về đa luồng.