From 9ebf16e3d9a43dbd6d0aa795383938b7b28695a3 Mon Sep 17 00:00:00 2001 From: Jesse Vincent Date: Tue, 10 Aug 2010 04:29:18 +0000 Subject: [PATCH] Finish removing the ThreadPool / ExecutorService Left over from when the code was actually in the view class --- .../fsck/k9/controller/MessagingController.java | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) diff --git a/src/com/fsck/k9/controller/MessagingController.java b/src/com/fsck/k9/controller/MessagingController.java index 887daf824..f32113cf0 100644 --- a/src/com/fsck/k9/controller/MessagingController.java +++ b/src/com/fsck/k9/controller/MessagingController.java @@ -18,8 +18,6 @@ import java.util.concurrent.BlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArraySet; import java.util.concurrent.CountDownLatch; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; import java.util.concurrent.PriorityBlockingQueue; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; @@ -139,8 +137,6 @@ public class MessagingController implements Runnable ConcurrentHashMap pushers = new ConcurrentHashMap(); - private final ExecutorService threadPool = Executors.newFixedThreadPool(5); - public enum SORT_TYPE { SORT_DATE(R.string.sort_earliest_first, R.string.sort_latest_first, false), @@ -402,7 +398,7 @@ public class MessagingController implements Runnable */ public void listFolders(final Account account, final boolean refreshRemote, final MessagingListener listener) { - threadPool.execute(new Runnable() + new Thread (new Runnable() { public void run() { @@ -458,7 +454,7 @@ public class MessagingController implements Runnable l.listFoldersFinished(account); } } - }); + }).start(); } private void doRefreshRemote(final Account account, MessagingListener listener) @@ -558,13 +554,13 @@ public class MessagingController implements Runnable */ public void listLocalMessages(final Account account, final String folder, final MessagingListener listener) { - threadPool.execute(new Runnable() + new Thread(new Runnable() { public void run() { listLocalMessagesSynchronous(account, folder, listener); } - }); + }).start(); } @@ -700,7 +696,7 @@ public class MessagingController implements Runnable + ")"); } - threadPool.execute(new Runnable() + new Thread(new Runnable() { public void run() { @@ -892,7 +888,7 @@ public class MessagingController implements Runnable listener.searchStats(stats); } } - }); + }).start(); } public void loadMoreMessages(Account account, String folder, MessagingListener listener)