2

Javaでは、オブジェクトをワーカースレッドからメインスレッドに戻す方法は? 例として、次のコードを取り上げます。

  main(String[] args) {

    String[] inputs;
    Result[] results;
    Thread[] workers = new WorkerThread[numThreads];

    for (int i = 0; i < numThreads; i++) {
        workers[i] = new WorkerThread(i, inputs[i], results[i]);
        workers[i].start();
    } 

    ....
  }
  ....

class WorkerThread extends Thread {
    String input;
    int name;
    Result result;

    WorkerThread(int name, String input, Result result) {
        super(name+"");
        this.name = name;
        this.input = input;
        this.result = result;
    }

    public void run() {
        result  = Processor.process(input);
    }
}

resultにバックを渡す方法はmain？results[i]

thisに渡すのはどうですかWorkerThread、

workers[i] = new WorkerThread(i, inputs[i], results[i], this);

できるように

mainThread.reults[i] = Processor.process(inputs[i]);
4

6 に答える 6

5

なぜCallablesと anを使わないのですExecutorServiceか?

main(String[] args) {

  String[] inputs;
  Future<Result>[] results;

  for (int i = 0; i < inputs.length; i++) {
    results[i] = executor.submit(new Worker(inputs[i]);
  } 
  for (int i = 0; i < inputs.length; i++) {
    Result r = results[i].get();
    // do something with the result
  }
}
于 2012-09-01T00:23:46.363 に答える
1

@Thiloと@Ericksonの答えが最高です。この種のことを簡単かつ確実に行う既存の API があります。

ただし、手動で行う現在のアプローチを維持したい場合は、コードを次のように変更するだけで十分な場合があります。

for (int i = 0; i < numThreads; i++) {
    results[i] = new Result();
    ...
    workers[i] = new WorkerThread(i, inputs[i], results[i]);
    workers[i].start();
}

...

public void run() {
    Result tmp = Processor.process(input);
    this.result.updateFrom(tmp);
    // ... where the updateFrom method copies the state of tmp into
    // the Result object that was passed from the main thread.
}

もう 1 つの方法はResult[]、メイン プログラムでa を置き換えて、結果オブジェクトで更新できる子スレッドにResult[][]渡すことです。Result[0]（軽量ホルダー）。

ただし、これを低レベルで実装する場合の重要な問題は、結果を取得する前に、メイン スレッドがすべての子スレッドで Thread.join を呼び出す必要があることです。そうしないと、メイン スレッドで Result オブジェクトに古い値が表示されることがあります。また、対応する子スレッドが完了する前にjoin、mainスレッドが Result にアクセスしようとしないようにします。

于 2012-09-01T00:43:36.780 に答える
0

私にはもっと良い解決策があると思います。ワーカースレッドに結果をlinkedListBlockingQueueに渡してもらい、それが完了した後に渡されます。メイン関数はこのようにキューから結果を取得します。

while(true){linkedListBlockingQueue.take(); 
    //todo: fil in the task you want it to do
    //if a specific kind of object is returned/countdownlatch is finished exit
}
于 2012-09-01T09:38:05.343 に答える
0

いくつかの典型的な解決策は次のとおりです。

  • 結果をワーカー スレッドのインスタンスに保持します (それRunnableまたはThread)。これは、Futureインターフェイスの使用に似ています。
  • BlockingQueue結果を格納できるワーカー スレッドが構築される を使用します。
  • ExecutorServiceおよびCallableインターフェイスを使用しFutureて、結果を求めることができる を取得します。
于 2012-09-01T00:28:40.690 に答える
0

あなたの目標は、計算を並行して実行することであるように見えます。その後、すべての結果がメインスレッドで利用可能になると、続行してそれらを使用できます。

その場合は、並列計算をCallableスレッドではなく として実装してください。invokeAll()このタスクのコレクションを のメソッドに渡しExecutorServiceます。このメソッドは、すべてのタスクが完了するまでブロックされます。その後、メイン スレッドは続行できます。

于 2012-09-01T00:39:05.507 に答える
0

メイン スレッドは、結果を取得する前に、ワーカー スレッドが完了するまで待機する必要があります。これを行う 1 つの方法は、メイン スレッドが各ワーカー スレッドが終了するのを待ってから、結果を読み取ろうとすることです。run() メソッドが完了すると、スレッドは終了します。

例えば：

for (int i = 0; i < workers.length; i++) {
  worker.join(); // wait for worker thread to terminate
  Result result = results[i]; // get the worker thread's result
  // process the result here...
}

ワーカー スレッドの結果が何らかの方法で result[] 配列に挿入されるように調整する必要があります。1 つの可能性として、配列とインデックスを各ワーカー スレッドに渡し、終了する前にワーカー スレッドに結果を割り当てさせることで、これを行うことができます。

于 2012-09-01T00:22:33.010 に答える