svn commit: r713465 - /maven/mercury/trunk/mercury-repo/mercury-repo-local-m2/src/main/java/org/apache/maven/mercury/repository/local/m2/LocalRepositoryWriterM2.java

[ogusakov]

Author: ogusakov
Date: Wed Nov 12 11:27:55 2008
New Revision: 713465

URL: http://svn.apache.org/viewvc?rev=713465&view=rev
Log:
modified the concurrent pattern

Modified:
    
maven/mercury/trunk/mercury-repo/mercury-repo-local-m2/src/main/java/org/apache/maven/mercury/repository/local/m2/LocalRepositoryWriterM2.java

Modified: 
maven/mercury/trunk/mercury-repo/mercury-repo-local-m2/src/main/java/org/apache/maven/mercury/repository/local/m2/LocalRepositoryWriterM2.java
URL: 
http://svn.apache.org/viewvc/maven/mercury/trunk/mercury-repo/mercury-repo-local-m2/src/main/java/org/apache/maven/mercury/repository/local/m2/LocalRepositoryWriterM2.java?rev=713465&r1=713464&r2=713465&view=diff
==============================================================================
--- 
maven/mercury/trunk/mercury-repo/mercury-repo-local-m2/src/main/java/org/apache/maven/mercury/repository/local/m2/LocalRepositoryWriterM2.java
 (original)
+++ 
maven/mercury/trunk/mercury-repo/mercury-repo-local-m2/src/main/java/org/apache/maven/mercury/repository/local/m2/LocalRepositoryWriterM2.java
 Wed Nov 12 11:27:55 2008
@@ -122,10 +122,7 @@
     LocalRepositoryWriterM2 [] workers = new LocalRepositoryWriterM2[ nWorkers 
];
     
     for( int i=0; i<nWorkers; i++ )
-    {
       workers[ i ] = new LocalRepositoryWriterM2( _repo, _repoDir, aq );
-      workers[ i ].start();
-    }
     
     for( Artifact artifact : artifacts )
     {
@@ -141,6 +138,9 @@
     }
     aq.addArtifact( LAST_ARTIFACT );
     
+    for( int i=0; i<nWorkers; i++ )
+      workers[ i ].start();
+    
     boolean alive = true;
     while( alive )
     {