You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@labs.apache.org by th...@apache.org on 2008/01/15 13:45:25 UTC
svn commit: r612108 -
/labs/droids/trunk/src/core/java/org/apache/droids/DefaultCrawler.java
Author: thorsten
Date: Tue Jan 15 04:45:21 2008
New Revision: 612108
URL: http://svn.apache.org/viewvc?rev=612108&view=rev
Log:
Breaking loop
Modified:
labs/droids/trunk/src/core/java/org/apache/droids/DefaultCrawler.java
Modified: labs/droids/trunk/src/core/java/org/apache/droids/DefaultCrawler.java
URL: http://svn.apache.org/viewvc/labs/droids/trunk/src/core/java/org/apache/droids/DefaultCrawler.java?rev=612108&r1=612107&r2=612108&view=diff
==============================================================================
--- labs/droids/trunk/src/core/java/org/apache/droids/DefaultCrawler.java (original)
+++ labs/droids/trunk/src/core/java/org/apache/droids/DefaultCrawler.java Tue Jan 15 04:45:21 2008
@@ -53,16 +53,10 @@
new LinkedBlockingQueue<Runnable>());
runningWorker=new ConcurrentHashMap<Integer,Worker>();
initQueue();
- doWork(0);
+ startWorkers(0);
Core.threadMessage("Finshed invocation, waiting for workers to finish.");
}
- private void doWork(int i) {
- while (queue.hasNext()) {
- startWorkers(x);
- }
- }
-
private synchronized int startWorkers(int x) {
Worker worker = getWorker();
worker.setId(x);
@@ -173,7 +167,10 @@
shutdownAndAwaitTermination();
Core.threadMessage("All threads has finished.");
}else if(queue.hasNext()){
- doWork(y);
+ for (int i = 0; i <getMaxThreads()-pool.getActiveCount(); i++) {
+ startWorkers(y+i);
+ }
+
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@labs.apache.org
For additional commands, e-mail: commits-help@labs.apache.org