java.util.concurrent.BlockingQueueの述語（/ find/search）が含まれていますか？

Question

java.util.concurrent.BlockingQueueが便利contains方法があります。

/** 
* Returns {@code true} if this queue contains the specified element. 
* More formally, returns {@code true} if and only if this queue contains 
* at least one element {@code e} such that {@code o.equals(e)}. 
* 
* @param o object to be checked for containment in this queue 
* @return {@code true} if this queue contains the specified element 
* @throws ClassCastException if the class of the specified element 
*   is incompatible with this queue 
*   (<a href="../Collection.html#optional-restrictions">optional</a>) 
* @throws NullPointerException if the specified element is null 
*   (<a href="../Collection.html#optional-restrictions">optional</a>) 
*/ 
public boolean contains(Object o); 

を私の必要性は、もう少し具体的です：predicate /検索条件を適用します。この短くする方法はありますか

Using a ArrayBlockQueue 
    Invoking toArray 

これは動作しますが、キューが大きい場合はどうなりますか？これはメモリ割り当ての問題を引き起こす可能性があります。

Answer 1

私はあなたがはこれを実行する必要があるかどうかわかりませんが、あなたはそれを行うことができますようにそれはそう：

public static class Matcher<T> { 

    Predicate<T> predicate; 
    Class<T> clazz; 

    public Matcher(Predicate<T> t, Class<T> clazz) { 
     this.predicate = t; 
     this.clazz = clazz; 
    } 

    @SuppressWarnings("unchecked") 
    public boolean equals(Object o) { 
     if (o != null && this.clazz.isInstance(o)) { 
      System.out.println("Checking item " + o + " against predicate " + this.predicate); 
      return this.predicate.test((T) o); 
     } 
     return false; 
    } 
} 

public static void main(String args[]) { 

    ArrayBlockingQueue<Integer> oddsOnly = new ArrayBlockingQueue<>(10); 
    oddsOnly.addAll(Arrays.asList(1, 3, 5, 7, 9, 11, 13)); 

    ArrayBlockingQueue<Integer> oddsAndEves = new ArrayBlockingQueue<>(10); 
    oddsAndEves.addAll(Arrays.asList(1, 2, 3, 4, 5)); 

    Predicate<Integer> evenPredicate = (i) -> i % 2 == 0; 
    System.out.println(oddsOnly.contains(new Matcher<>(evenPredicate, Integer.class))); // prints false 

    System.out.println(oddsAndEves.contains(new Matcher<>(evenPredicate, Integer.class))); // prints true 
} 

出力：

Checking item 1 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
Checking item 3 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
Checking item 5 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
Checking item 7 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
Checking item 9 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
Checking item 11 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
Checking item 13 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
false 
Checking item 1 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
Checking item 2 against predicate QueueEquals$Matcher$$Lambda$1/531885035@816f27d 
true 

をそれは私が望ん作るんしかし、シャワーを浴びる...プラス、pvgが正しく指摘している - これは動作するとは限りません。 BlockingQueueの実装は、equals()を呼び出す前にhashCode()を呼び出すことがあります。

sanerオプションは、ブロッキングキューを反復処理し、各要素に対して述語を実行することです。 BlockingQueueインターフェイスにはiteratorがありませんが、多くのブロックキューの実装（ArrayBlockingQueue、LinkedBlockingQueueなど）があります。

Answer 2

Queue（必要に応じて並行して）をストリームして、述語を使用して要素を除外することができます。 BlockingQueueはQueueであり、これはCollectionであり、したがってstream()とparallelStream()と定義します。以下に沿って何か：

次の出力見つかった値を持つ

public class SampleApplication { 

    private static final int ELEMENT_COUNT = 100000; 

    public static void main(String[] args) { 
     Queue<Element> blockingQueue = new ArrayBlockingQueue<>(ELEMENT_COUNT); 
     List<Element> elements = Stream.generate(SampleApplication::createElement).limit(ELEMENT_COUNT).collect(Collectors.toList()); 
     blockingQueue.addAll(elements); 

     blockingQueue.stream().filter(getFilterPredicate(5)).findAny().ifPresent(System.out::println); 
     blockingQueue.stream().filter(getFilterPredicate(105)).findAny().ifPresent(System.out::println); 
     blockingQueue.stream().filter(getFilterPredicate(-1)).findAny().ifPresent(System.out::println); 
    } 

    private static Predicate<Element> getFilterPredicate(int value) { 
     return e -> e.getId() == value; 
    } 

    private static int i = 0; 
    private static Element createElement() { 
     return new Element(++i); 
    } 

    static class Element { 
     private int id; 
     private String message; 

     public Element(int id) { 
      this.id = id; 
      this.message = "Default msg"; 
     } 

     //Getters, Setters & toString omitted 
    } 
} 

：

Element{id=5, message=Default msg} 
Element{id=105, message=Default msg}