Permalink
Browse files

Merge pull request #156 from jentfoo/concurrency_classpath_extension

Adding more java.util.concurrent interfaces that were missed previously.
  • Loading branch information...
2 parents 522e8ca + 2aa9de3 commit c3638b7d100fc32710222f937819667d48942cef @dicej dicej committed Jan 10, 2014
@@ -0,0 +1,20 @@
+package java.util.concurrent;
+
+import java.util.Collection;
+import java.util.Queue;
+
+public interface BlockingQueue<T> extends Queue<T> {
+ public void put(T e) throws InterruptedException;
+
+ public boolean offer(T e, long timeout, TimeUnit unit) throws InterruptedException;
+
+ public T take() throws InterruptedException;
+
+ public T poll(long timeout, TimeUnit unit) throws InterruptedException;
+
+ public int remainingCapacity();
+
+ public int drainTo(Collection<? super T> c);
+
+ public int drainTo(Collection<? super T> c, int maxElements);
+}
@@ -0,0 +1,13 @@
+package java.util.concurrent;
+
+public interface CompletionService<T> {
+ public Future<T> submit(Callable<T> task);
+
+ public Future<T> submit(Runnable task, T result);
+
+ public Future<T> take() throws InterruptedException;
+
+ public Future<T> poll();
+
+ public Future<T> poll(long timeout, TimeUnit unit) throws InterruptedException;
+}
@@ -0,0 +1,5 @@
+package java.util.concurrent;
+
+public interface RunnableFuture<T> extends Runnable, Future<T> {
+ // nothing added to interface
+}
@@ -0,0 +1,19 @@
+package java.util.concurrent;
+
+public interface ScheduledExecutorService extends ExecutorService {
+ public ScheduledFuture<?> schedule(Runnable command,
+ long delay, TimeUnit unit);
+
+ public <V> ScheduledFuture<V> schedule(Callable<V> callable,
+ long delay, TimeUnit unit);
+
+ public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
+ long initialDelay,
+ long period,
+ TimeUnit unit);
+
+ public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
+ long initialDelay,
+ long delay,
+ TimeUnit unit);
+}
@@ -0,0 +1,5 @@
+package java.util.concurrent;
+
+public interface ThreadFactory {
+ public Thread newThread(Runnable r);
+}

0 comments on commit c3638b7

Please sign in to comment.