Add getActiveCount() to return active ajax threads.

Author: androidquery

src/com/androidquery/callback/AbstractAjaxCallback.java

@@ -38,6 +38,7 @@
 import java.util.Map;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadPoolExecutor;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.zip.GZIPInputStream;
@@ -1279,6 +1280,24 @@ public static void execute(Runnable job){
 		fetchExe.execute(job);
 	}
 
+	/**
+	 * Return the number of active ajax threads. Note that this doesn't necessarily correspond to active network connections.
+	 * Ajax threads might be reading a cached url from file system or transforming the response after a network transfer. 
+	 * 
+	 */
+	
+	public static int getActiveCount(){
+		
+		int result = 0;
+		
+		if(fetchExe instanceof ThreadPoolExecutor){
+			result = ((ThreadPoolExecutor) fetchExe).getActiveCount();
+		}
+		
+		return result;
+		
+	}
+	
 	/**
 	 * Sets the simultaneous network threads limit. Highest limit is 25.
 	 *

tests/src/com/androidquery/test/AQueryAsyncTest.java

@@ -1644,5 +1644,32 @@ public void callback(String url, JSONObject jo, AjaxStatus status) {
         assertNotNull(file);
 
 
+    }
+	
+	
+	public void testAjaxActiveCount() {
+		
+		assertEquals(0, AjaxCallback.getActiveCount());
+        
+		
+		String url = "http://www.google.com/uds/GnewsSearch?q=Obama&v=1.0";
+        
+        aq.ajax(url, JSONObject.class, this, "jsonCb");
+        
+        
+        int count = AjaxCallback.getActiveCount();
+        AQUtility.debug("active count", count);
+        
+        assertEquals(1, AjaxCallback.getActiveCount());
+        
+        waitAsync();
+        
+        assertEquals(0, AjaxCallback.getActiveCount());
+        
+        JSONObject jo = (JSONObject) result;
+        
+        assertNotNull(jo);       
+        assertNotNull(jo.opt("responseData"));
+        
     }
 }

tests/src/com/androidquery/test/AQueryImageTest.java

@@ -474,6 +474,8 @@ public void run() {
 
 				Bitmap bm = aq.getCachedImage(R.drawable.icon);
 				assertNotNull(bm);
+				
+				
 			}
 		});
 
@@ -483,4 +485,25 @@ public void run() {
 
     }	
 
+	public void testIfModified() {
+		
+		String url = ICON_URL;
+		
+		AjaxCallback<Bitmap> cb = new AjaxCallback<Bitmap>();
+		cb.type(Bitmap.class).url(url);
+		
+		aq.sync(cb);
+		
+		Bitmap bm = cb.getResult();
+		AjaxStatus status = cb.getStatus();
+		
+		assertNotNull(bm);
+		
+		assertEquals(304, status.getCode());
+		
+		File file;
+		
+		
+	}
+	
 }