Очередь блокировки Java, содержащая только уникальные элементы

Question

вроде как «блокирующий набор».Как реализовать очередь блокировки, при которой добавление члена, уже находящегося в наборе, игнорируется?

Answer 1

Я написал этот класс для решения аналогичной проблемы:

/**
 * Linked blocking queue with {@link #add(Object)} method, which adds only element, that is not already in the queue.
 */
public class SetBlockingQueue<T> extends LinkedBlockingQueue<T> {

    private Set<T> set = Collections.newSetFromMap(new ConcurrentHashMap<>());

    /**
     * Add only element, that is not already enqueued.
     * The method is synchronized, so that the duplicate elements can't get in during race condition.
     * @param t object to put in
     * @return true, if the queue was changed, false otherwise
     */
    @Override
    public synchronized boolean add(T t) {
        if (set.contains(t)) {
            return false;
        } else {
            set.add(t);
            return super.add(t);
        }
    }

    /**
     * Takes the element from the queue.
     * Note that no synchronization with {@link #add(Object)} is here, as we don't care about the element staying in the set longer needed.
     * @return taken element
     * @throws InterruptedException
     */
    @Override
    public T take() throws InterruptedException {
        T t = super.take();
        set.remove(t);
        return t;
    }
}

Answer 2

Вы можете создать новый класс, который будет составлять BlockingQueue, Set и блокировку.Когда вы ставите (), вы проверяете набор, удерживая блокировку, которая мешает запуску get ()Когда вы получаете (), вы удаляете элемент из набора, чтобы в будущем его можно было снова поместить ().

Answer 3

Реализация блокирующей очереди, подкрепленная связанным хеш-набором для предсказуемого порядка итерации и добавления, удаления с постоянным временем и содержит операции:

Вот и все .

Answer 4

class BlockingSet extends ArrayBlockingQueue<E> {
   /*Retain all other methods except put*/
   public void put(E o) throws InterruptedException {
      if (!this.contains(o)){
         super.put(o);
      }
   }
}

Answer 5

Вы можете переопределить методы add и put любой реализации BlockingQueue<T>, чтобы сначала проверить, находится ли элемент уже в очереди, например,

@Override
public boolean add(T elem) {
    if (contains(elem))
        return true;
    return super.add(elem);
}