本文整理了Java中java.util.concurrent.LinkedBlockingQueue.contains()方法的一些代码示例，展示了LinkedBlockingQueue.contains()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。LinkedBlockingQueue.contains()方法的具体详情如下：
包路径：java.util.concurrent.LinkedBlockingQueue
类名称：LinkedBlockingQueue
方法名：contains

LinkedBlockingQueue.contains介绍

[英]Returns true if this queue contains the specified element. More formally, returns true if and only if this queue contains at least one element e such that o.equals(e).
[中]如果此队列包含指定的元素，则返回true。更正式地说，当且仅当此队列包含至少一个元素e，使得o.equals（e）时，返回true。

代码示例

代码示例来源：origin: jankotek/mapdb

/**
 * contains(x) reports true when elements added but not yet removed
 */
public void testContains() {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  for (int i = 0; i < SIZE; ++i) {
    assertTrue(q.contains(new Integer(i)));
    q.poll();
    assertFalse(q.contains(new Integer(i)));
  }
}

代码示例来源：origin: jankotek/mapdb

/**
 * all elements successfully put are contained
 */
public void testPut() throws InterruptedException {
  LinkedBlockingQueue q = new LinkedBlockingQueue(SIZE);
  for (int i = 0; i < SIZE; ++i) {
    Integer x = new Integer(i);
    q.put(x);
    assertTrue(q.contains(x));
  }
  assertEquals(0, q.remainingCapacity());
}

代码示例来源：origin: AsyncHttpClient/async-http-client

assertFalse(err.get());
assertEquals(queue.size(), 2);
assertTrue(queue.contains("part1"));
assertTrue(queue.contains("part2"));
assertTrue(status.get());
assertEquals(headers.get(), 1);

代码示例来源：origin: jankotek/mapdb

/**
 * drainTo(c) empties queue into another collection c
 */
public void testDrainTo() {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  ArrayList l = new ArrayList();
  q.drainTo(l);
  assertEquals(0, q.size());
  assertEquals(SIZE, l.size());
  for (int i = 0; i < SIZE; ++i)
    assertEquals(l.get(i), new Integer(i));
  q.add(zero);
  q.add(one);
  assertFalse(q.isEmpty());
  assertTrue(q.contains(zero));
  assertTrue(q.contains(one));
  l.clear();
  q.drainTo(l);
  assertEquals(0, q.size());
  assertEquals(2, l.size());
  for (int i = 0; i < 2; ++i)
    assertEquals(l.get(i), new Integer(i));
}

代码示例来源：origin: jankotek/mapdb

/**
 * iterator iterates through all elements
 */
public void testIterator() throws InterruptedException {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  Iterator it = q.iterator();
  int i;
  for (i = 0; it.hasNext(); i++)
    assertTrue(q.contains(it.next()));
  assertEquals(i, SIZE);
  assertIteratorExhausted(it);
  it = q.iterator();
  for (i = 0; it.hasNext(); i++)
    assertEquals(it.next(), q.take());
  assertEquals(i, SIZE);
  assertIteratorExhausted(it);
}

代码示例来源：origin: jankotek/mapdb

/**
 * removeAll(c) removes only those elements of c and reports true if changed
 */
public void testRemoveAll() {
  for (int i = 1; i < SIZE; ++i) {
    LinkedBlockingQueue q = populatedQueue(SIZE);
    LinkedBlockingQueue p = populatedQueue(i);
    assertTrue(q.removeAll(p));
    assertEquals(SIZE - i, q.size());
    for (int j = 0; j < i; ++j) {
      Integer x = (Integer)(p.remove());
      assertFalse(q.contains(x));
    }
  }
}

代码示例来源：origin: hector-client/hector

public boolean contains(CassandraHost cassandraHost) {
 return downedHostQueue.contains(cassandraHost);
}

代码示例来源：origin: jankotek/mapdb

/**
 * clear removes all elements
 */
public void testClear() {
  LinkedBlockingQueue q = populatedQueue(SIZE);
  q.clear();
  assertTrue(q.isEmpty());
  assertEquals(0, q.size());
  assertEquals(SIZE, q.remainingCapacity());
  q.add(one);
  assertFalse(q.isEmpty());
  assertTrue(q.contains(one));
  q.clear();
  assertTrue(q.isEmpty());
}

代码示例来源：origin: hector-client/hector

@Override
 public void run() {
  if(downedHostQueue.contains(cassandraHost) && verifyConnection(cassandraHost)) {
   if (connectionManager.addCassandraHost(cassandraHost)) {
    listenerHandler.fireOnHostRestored(cassandraHost);
    downedHostQueue.remove(cassandraHost);
   }
   return;
  }
 }
});

代码示例来源：origin: vilyever/AndroidSocketClient

@Override
  public void run() {
    synchronized (getSendingPacketQueue()) {
      if (self.getSendingPacketQueue().contains(packet)) {
        self.getSendingPacketQueue().remove(packet);
        self.__i__onSendPacketCancel(packet);
      }
    }
  }
}).start();

代码示例来源：origin: stackoverflow.com

class NoDupBlockingQueue<T> extends LinkedBlockingQueue<T> {
  @Override
  public void put(T e) throws InterruptedException {
    if (!contains(e))
      super.put(e);
  }
}

代码示例来源：origin: jzyong/game-server

public boolean contains(Runnable runnable) {
  return command_queue.contains(runnable);
}

代码示例来源：origin: igniterealtime/Spark

/**
 * Adds a jid to lookup vCard.
 *
 * @param jid the jid to lookup.
 */
public void addToQueue(BareJid jid) {
  if (!queue.contains(jid)) {
    queue.add(jid);
  }
}

代码示例来源：origin: firelotus/Meteorite

@Override
public void add(@NonNull Transaction runnable) {
  synchronized (queue) {
    if (!queue.contains(runnable)) {
      queue.add(runnable);
    }
  }
}

代码示例来源：origin: jzyong/game-server

public void execute(Runnable command, boolean checkOnly) {
  try {
    if (checkOnly && command_queue.contains(command)) {
      return;
    }
    command_queue.add(command);
    synchronized (this) {
      notify();
    }
  } catch (Exception e) {
    log.error("Main Thread " + threadName + " Notify Exception:" + e.getMessage());
  }
}

代码示例来源：origin: baratine/baratine

protected void queueEvent(JWatchKey event)
{
 synchronized (this) {
  if (_eventQueue.contains(event)) {
   throw new IllegalStateException(L.l("watch key already signaled: {0}", event));
  }
  _eventQueue.add(event);
 }
}

代码示例来源：origin: Blankeer/XAndroidSocket

public boolean enqueueTcpMsg(final TcpMsg tcpMsg) {
    if (tcpMsg == null || getMsgQueue().contains(tcpMsg)) {
      return false;
    }
    try {
      getMsgQueue().put(tcpMsg);
      return true;
    } catch (InterruptedException e) {
//            e.printStackTrace();
    }
    return false;
  }

代码示例来源：origin: Blankeer/XAndroidSocket

public boolean enqueueUdpMsg(final UdpMsg tcpMsg) {
      if (tcpMsg == null || getSendingMsg() == tcpMsg
          || getMsgQueue().contains(tcpMsg)) {
        return false;
      }
      try {
        getMsgQueue().put(tcpMsg);
        return true;
      } catch (InterruptedException e) {
//                e.printStackTrace();
      }
      return false;
    }

代码示例来源：origin: me.prettyprint/hector-core

@Override
 public void run() {
  if(downedHostQueue.contains(cassandraHost) && verifyConnection(cassandraHost)) {
   if (connectionManager.addCassandraHost(cassandraHost)) {
    listenerHandler.fireOnHostRestored(cassandraHost);
    downedHostQueue.remove(cassandraHost);
   }
   return;
  }
 }
});

代码示例来源：origin: org.hectorclient/hector-core

@Override
 public void run() {
  if(downedHostQueue.contains(cassandraHost) && verifyConnection(cassandraHost)) {
   if (connectionManager.addCassandraHost(cassandraHost)) {
    listenerHandler.fireOnHostRestored(cassandraHost);
    downedHostQueue.remove(cassandraHost);
   }
   return;
  }
 }
});