diff options
author | Samuel Tardieu <sam@rfc1149.net> | 2014-11-20 19:56:32 +0100 |
---|---|---|
committer | Samuel Tardieu <sam@rfc1149.net> | 2014-11-20 19:56:32 +0100 |
commit | 22db5cfa36a5ebe4d87bbe0c1065ae4d6621a3c5 (patch) | |
tree | 00d26352f0a9f78b10ec8ec6d115453b2d3509fa | |
parent | f8a8fb2b33fa41832f0fc3c027611e67a9daced6 (diff) | |
download | cgeo-22db5cfa36a5ebe4d87bbe0c1065ae4d6621a3c5.zip cgeo-22db5cfa36a5ebe4d87bbe0c1065ae4d6621a3c5.tar.gz cgeo-22db5cfa36a5ebe4d87bbe0c1065ae4d6621a3c5.tar.bz2 |
Use a scheduler instead of a thread to remove old directories
-rw-r--r-- | main/src/cgeo/geocaching/DataStore.java | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/main/src/cgeo/geocaching/DataStore.java b/main/src/cgeo/geocaching/DataStore.java index 632e13e..58eb7e5 100644 --- a/main/src/cgeo/geocaching/DataStore.java +++ b/main/src/cgeo/geocaching/DataStore.java @@ -29,6 +29,7 @@ import org.apache.commons.lang3.StringUtils; import org.eclipse.jdt.annotation.NonNull; import rx.android.observables.AndroidObservable; +import rx.functions.Action0; import rx.functions.Action1; import rx.functions.Func0; import rx.functions.Func1; @@ -879,15 +880,15 @@ public class DataStore { // Use a background thread for the real removal to avoid keeping the database locked // if we are called from within a transaction. - new Thread(new Runnable() { + Schedulers.io().createWorker().schedule(new Action0() { @Override - public void run() { + public void call() { for (final File dir : toRemove) { Log.i("Removing obsolete cache directory for " + dir.getName()); LocalStorage.deleteDirectory(dir); } } - }).start(); + }); } } |