スレッドが同時に起動しないのはなぜですか？ Java

Question

私は並列ダウンロードに使用されるスレッドの数が可変です。私はなぜ知らないが、彼らが完了するまでにお互いを待つ

for(int i = 0; i< sth; i++){ 
     thrList.add(new myThread (parameters)); 
     thrList.get(i).start(); 
     thrList.get(i).join(); 

}

、これを使用していました。スレッドを使用しているときは、すぐにそのコードを実行するスレッドがいくつかあるので、私は混在したプリントアウトを取得することになっています。しかし、私がそれらをプリントアウトすると、それらは常に順番になり、1つのスレッドは前のものが最初に終了するのを待ちます。私は、彼らがお互いを待つのではなく、メインスレッドに参加したいだけです。私は並行してダウンロード中に時間を測定したときに気づいた。

どうすればこの問題を解決できますか？なぜ彼らはそれを順番にやっているのですか？

私の.javaには、 があります。実行中のMyThreadクラスがあり、静的メソッドと変数を持つDownloaderクラスがあります。彼らはこれの原因だろうか？静的メソッドと変数

この問題を解決するにはどうすればよいですか？

Answer 1

あなたはちょうどそれらすべてに参加し、その後、それらのすべてを最初に起動し、2つのループを行うExecutorServiceの

ExecutorService es = Executors.newCachedThreadPool(); 
// pool is reusable 

List<Callable<Void>> callables = new ArrayList<Callable<Void>>(); 
for(int i=0;i<sth;i++) callables.add(new MyCallable(i)); 
for(Future<Void> futures : es.invokeAll(callables)) 
    futures.get(); 

Answer 2

スレッドを作成して、完了（ジョイン）、新しいスレッドの作成、完了（ジョイン）などの待機を待っています。

あなたは、ほとんどの方法は何をすべきか知っているスレッドに関するJavaドキュメントを読んでください： http://download.oracle.com/javase/tutorial/essential/concurrency/index.htmlと

Answer 3

http://download.oracle.com/javase/6/docs/api/java/lang/Thread.htmlあなたが待っていると、無駄な全スレッドをレンダリング、それに参加し、すぐにスレッドを開始し、スレッドの完了。

thrList.get(i).start(); 
    thrList.get(i).join(); 

スポーンされたスレッド自体がパラメータを取得し、キューが空になるまで待ってから続行する同期キューを使用する必要があります。

Answer 4

簡単。問題は次のとおりです。

具体的には、ループを繰り返すたびにスレッドが作成され、スレッドが再び参加するのを待っています。これが彼らが連続して走っている理由です。すべてのスレッドを起動するプロセスを通過します

for(int i = 0; i< sth; i++){ 
     thrList.add(new myThread (parameters)); 
     thrList.get(i).start(); 
} 

for(int i = 0; i< sth; i++){ 
     thrList.get(i).join(); 
} 

それがする各スレッドをループし、それが終了するのを待ち：

は何をする必要があると、このです。

Answer 5

joinメソッドは、選択されたスレッドが終了するのを待ちます。現在のスレッド（イベントを発生させるループを実行しているスレッド）は、直前にスレッドを終了し、次のスレッドを開始する前にスレッドを待機しています。

Answer 6

を使用してオフにはるかに優れています。

Answer 7

あなたの質問から私が解釈するものは、明確に述べられていないので、いくつかのダウンローダスレッドがあり、それらを同期したいということです。その場合は、CountdownLatchのような外部構造を使用する必要があります。CountdownLatchは、「他のスレッドで実行されている一連の操作が完了するまで、1つまたは複数のスレッドを待機させる同期補助機能」です。ダウンローダスレッドが終了するたびにカウントダウンが0に達すると、すべてのスレッドが作業を完了する必要があるたびに減少するカウンタと考えることができます。

のは、たCountDownLatchの公式のjavadocから直接取得いくつかのコードを見てみましょう：

CountDownLatch startSignal = new CountDownLatch(1); 
CountDownLatch doneSignal = new CountDownLatch(N); 

for (int i = 0; i < N; ++i) // create and start threads 
    new Thread(new Worker(startSignal, doneSignal)).start(); 

startSignal.countDown(); // Threads are waiting for startSignal's counter to reach 0 and start their work, more or less at the same time 
doneSignal.await(); // The current thread will sleep at this point until all worker threads have each one called doneSignal.countDown() and the countdown reaches 0 

joinDownloadedPieces(); // At this point is safe to assume that your threads have finished and you can go on with anything else  

あなたの労働者のRunnable/Threadクラスは、このようなものになります。

public void run() { 
    startSignal.await(); // Wait until given the go 

    downloadSomething(); 

    doneSignal.countDown(); // Notify that we are done here 
} 

を私は以来と仮定しても安全であると言いますInterruptedExceptionsを処理する必要があります。InterruptedExceptionsは、待機中にスレッドをスリープ状態にすることができます。詳細については、java.util.concurrentパッケージをご覧ください。それはJavaの最高の宝石の一つであり、ドキュメンテーションは徹底しており、多くの場合、各構造の機能を理解するのに十分です。