You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@maven.apache.org by og...@apache.org on 2008/11/12 20:27:57 UTC

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

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 )
     {