FutureThread constructor

koush · koush · commit e26525dc0e3d · 2015-03-02T23:52:33.000-08:00
diff --git a/AndroidAsync/AndroidAsync-AndroidAsync.iml b/AndroidAsync/AndroidAsync-AndroidAsync.iml
@@ -80,9 +80,7 @@
       <excludeFolder url="file://$MODULE_DIR$/build/intermediates/res" />
       <excludeFolder url="file://$MODULE_DIR$/build/intermediates/rs" />
       <excludeFolder url="file://$MODULE_DIR$/build/intermediates/symbols" />
-      <excludeFolder url="file://$MODULE_DIR$/build/libs" />
       <excludeFolder url="file://$MODULE_DIR$/build/outputs" />
-      <excludeFolder url="file://$MODULE_DIR$/build/poms" />
       <excludeFolder url="file://$MODULE_DIR$/build/tmp" />
     </content>
     <orderEntry type="jdk" jdkName="Android API 21 Platform" jdkType="Android SDK" />
diff --git a/AndroidAsync/src/com/koushikdutta/async/future/FutureThread.java b/AndroidAsync/src/com/koushikdutta/async/future/FutureThread.java
@@ -1,5 +1,7 @@
 package com.koushikdutta.async.future;
 
+import java.util.concurrent.ExecutorService;
+
 /**
  * Created by koush on 12/22/13.
  */
@@ -8,6 +10,20 @@ public FutureThread(final FutureRunnable<T> runnable) {
         this(runnable, "FutureThread");
     }
 
+    public FutureThread(final ExecutorService pool, final FutureRunnable<T> runnable) {
+        pool.submit(new Runnable() {
+            @Override
+            public void run() {
+                try {
+                    setComplete(runnable.run());
+                }
+                catch (Exception e) {
+                    setComplete(e);
+                }
+            }
+        });
+    }
+
     public FutureThread(final FutureRunnable<T> runnable, String name) {
         new Thread(new Runnable() {
             @Override
diff --git a/AndroidAsyncStetho/AndroidAsyncStetho.iml b/AndroidAsyncStetho/AndroidAsyncStetho.iml
