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