From 2aa9de3dfbbd0687522123f42682f9360b97b6fd Mon Sep 17 00:00:00 2001
From: Mike Jensen <mike.jensen@readytalk.com>
Date: Thu, 9 Jan 2014 09:50:15 -0700
Subject: [PATCH] More interfaces that were missed previously.

---
 .../java/util/concurrent/BlockingQueue.java   | 20 +++++++++++++++++++
 .../util/concurrent/CompletionService.java    | 13 ++++++++++++
 .../java/util/concurrent/RunnableFuture.java  |  5 +++++
 .../concurrent/ScheduledExecutorService.java  | 19 ++++++++++++++++++
 .../java/util/concurrent/ThreadFactory.java   |  5 +++++
 5 files changed, 62 insertions(+)
 create mode 100644 classpath/java/util/concurrent/BlockingQueue.java
 create mode 100644 classpath/java/util/concurrent/CompletionService.java
 create mode 100644 classpath/java/util/concurrent/RunnableFuture.java
 create mode 100644 classpath/java/util/concurrent/ScheduledExecutorService.java
 create mode 100644 classpath/java/util/concurrent/ThreadFactory.java

diff --git a/classpath/java/util/concurrent/BlockingQueue.java b/classpath/java/util/concurrent/BlockingQueue.java
new file mode 100644
index 000000000..74c1ab404
--- /dev/null
+++ b/classpath/java/util/concurrent/BlockingQueue.java
@@ -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);
+}
diff --git a/classpath/java/util/concurrent/CompletionService.java b/classpath/java/util/concurrent/CompletionService.java
new file mode 100644
index 000000000..16e071f90
--- /dev/null
+++ b/classpath/java/util/concurrent/CompletionService.java
@@ -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;
+}
diff --git a/classpath/java/util/concurrent/RunnableFuture.java b/classpath/java/util/concurrent/RunnableFuture.java
new file mode 100644
index 000000000..cb31af453
--- /dev/null
+++ b/classpath/java/util/concurrent/RunnableFuture.java
@@ -0,0 +1,5 @@
+package java.util.concurrent;
+
+public interface RunnableFuture<T> extends Runnable, Future<T> {
+  // nothing added to interface
+}
diff --git a/classpath/java/util/concurrent/ScheduledExecutorService.java b/classpath/java/util/concurrent/ScheduledExecutorService.java
new file mode 100644
index 000000000..c3756686f
--- /dev/null
+++ b/classpath/java/util/concurrent/ScheduledExecutorService.java
@@ -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);
+}
diff --git a/classpath/java/util/concurrent/ThreadFactory.java b/classpath/java/util/concurrent/ThreadFactory.java
new file mode 100644
index 000000000..60c13235e
--- /dev/null
+++ b/classpath/java/util/concurrent/ThreadFactory.java
@@ -0,0 +1,5 @@
+package java.util.concurrent;
+
+public interface ThreadFactory {
+  public Thread newThread(Runnable r);
+}