aboutsummaryrefslogtreecommitdiffstats
path: root/AndroidAsync
diff options
context:
space:
mode:
authorKoushik Dutta <koushd@gmail.com>2015-03-02 23:52:28 -0800
committerKoushik Dutta <koushd@gmail.com>2015-03-02 23:52:33 -0800
commite26525dc0e3dc759c550fc79e43eb49330175d4e (patch)
tree2998b66d4c8ed0394da57a0da6afa846e2819e28 /AndroidAsync
parent257c09449ce3ab54b0d23d132d9a4130e0cea896 (diff)
downloadAndroidAsync-e26525dc0e3dc759c550fc79e43eb49330175d4e.tar.gz
AndroidAsync-e26525dc0e3dc759c550fc79e43eb49330175d4e.tar.bz2
AndroidAsync-e26525dc0e3dc759c550fc79e43eb49330175d4e.zip
FutureThread constructor
Diffstat (limited to 'AndroidAsync')
-rw-r--r--AndroidAsync/AndroidAsync-AndroidAsync.iml2
-rw-r--r--AndroidAsync/src/com/koushikdutta/async/future/FutureThread.java16
2 files changed, 16 insertions, 2 deletions
diff --git a/AndroidAsync/AndroidAsync-AndroidAsync.iml b/AndroidAsync/AndroidAsync-AndroidAsync.iml
index e9527e9..9b372cd 100644
--- 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
index 37091e6..5f527e0 100644
--- 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 class FutureThread<T> extends SimpleFuture<T> {
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