2026-03-17 13:31:18 -07:00

29 lines
677 B
Java

package com.tridium.util.backport.concurrent;
import com.tridium.util.backport.Queue;
import java.util.Collection;
public interface BlockingQueue extends Queue {
boolean add(Object obj);
boolean contains(Object obj);
int drainTo(Collection collection);
int drainTo(Collection collection, int i);
boolean offer(Object obj);
boolean offer(Object obj, long j, TimeUnit timeUnit) throws InterruptedException;
Object poll(long j, TimeUnit timeUnit) throws InterruptedException;
void put(Object obj) throws InterruptedException;
int remainingCapacity();
boolean remove(Object obj);
Object take() throws InterruptedException;
}