From 1503da8ce1e116332bd81abc25fa550da13a43cb Mon Sep 17 00:00:00 2001
From: Scott Jackson <daneren2005@gmail.com>
Date: Tue, 11 Feb 2014 18:58:22 -0800
Subject: Fix web commit

---
 src/github/daneren2005/dsub/util/BackgroundTask.java | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

(limited to 'src/github/daneren2005')

diff --git a/src/github/daneren2005/dsub/util/BackgroundTask.java b/src/github/daneren2005/dsub/util/BackgroundTask.java
index 4ff1f20a..4e71188f 100644
--- a/src/github/daneren2005/dsub/util/BackgroundTask.java
+++ b/src/github/daneren2005/dsub/util/BackgroundTask.java
@@ -20,6 +20,11 @@ package github.daneren2005.dsub.util;
 
 import java.io.FileNotFoundException;
 import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
 
 import org.xmlpull.v1.XmlPullParserException;
 
@@ -37,16 +42,16 @@ public abstract class BackgroundTask<T> implements ProgressListener {
 
     private final Activity activity;
 
-	private static final DEFAULT_CONCURRENCY = 5;
+	private static final int DEFAULT_CONCURRENCY = 5;
 	private static final Collection<Thread> threads = Collections.synchronizedCollection(new ArrayList<Thread>(DEFAULT_CONCURRENCY));
-	private static final BlockingQueue<Task> queue = new BlockingQueue<Task>(10);
+	protected static final BlockingQueue<BackgroundTask.Task> queue = new LinkedBlockingQueue<BackgroundTask.Task>(10);
 	private static final Handler handler = new Handler();
 
     public BackgroundTask(Activity activity) {
         this.activity = activity;
 
 		if(threads.isEmpty()) {
-			for(int i = 0; i < DEFAULT_CONCURRENY; i++) {
+			for(int i = 0; i < DEFAULT_CONCURRENCY; i++) {
 				Thread thread = new Thread(new TaskRunnable(), String.format("BackgroundTask_%d", i));
 				threads.add(thread);
 				thread.start();
@@ -132,7 +137,7 @@ public abstract class BackgroundTask<T> implements ProgressListener {
 						onDone(result);
 					}
 				});
-			} catch(Throwable t) {
+			} catch(final Throwable t) {
 				if(isCancelled()) {
 					return;
 				}
@@ -158,7 +163,7 @@ public abstract class BackgroundTask<T> implements ProgressListener {
 		}
 	}
 
-	private class TaskRunnable extends Runnable {
+	private class TaskRunnable implements Runnable {
 		private boolean running = true;
 
 		public TaskRunnable() {
-- 
cgit v1.2.3