複数のスレッドでリストを実行するためにハッシュセットを分離

Question

私はグーグルでこの質問を検索し、私が探しているものに似たものは見つかりませんでした。

Personと呼ばれるオブジェクトがほとんどないHashSetが作成されました。これらのPersonを巨大なテキストで検索するために4〜5つのスレッドを設定する必要があります。スレッドは、ハードウェアの使い方を最適化するソリューションです。

このHashSetを分離して4つのスレッドを開始するにはどうしたらいいですか？私は新しいHashSetリストを作成し、この新しいハッシュセットを4で分割して新しいスレッドを作成しようとしました。

これは良い解決策に見えますが、それを行う良い方法はありますか？ハッシュセットを分割して、4〜5個の新しいスレッドに分割して送信するにはどうすればよいですか？

Answer 1

プロデューサ/コンシューマスキームを実装できます。単一のスレッドがハッシュセットから値を1つずつ読み込んでキューに入れ、複数のワーカースレッドによって処理されるようにします。 ExecutorServiceクラスを使用して、ワーカーを管理することができます。

編集：ここではあなたが何ができるかです：

は、あなたのワーカークラスを定義します。

ExecutorService s = Executors.newCachedThreadPool(); 
for(Person p: hashSet) { 
    s.submit(new Worker(p)); 
} 

Answer 2

考慮すべき物事のカップル：

メインスレッドで

public class Worker implements Runnable { 
    private Person p; 

    public Worker(Person p) { 
     this.p = p; 
    }  

    public void run() { 
     // search for p 
    } 
} 

を

1）同じハッシュを使用できます設定しますが、同期させる必要があります（呼び出しを​​ブロックで囲みます）。しかし、あなたがやっているのは、ハッシュで物事を探しているのであれば、マルチスレッド化されてもそれほどあなたを買わないでしょう。

2）HashSetを分割する場合は、キー範囲の分割を検討することができます。たとえば、名前を検索している場合、A-Fで始まる名前はHashSet1、G-L HashSet2などになります。このようにして検索を完全に並行させることができます。

Answer 3

Iteratorを使用してハッシュセットを反復処理します。 &を繰り返しながら、値をフェッチしてスレッドを作成して起動します。

エルス

あなたは同時タスクを並列に実行できるExecutorServiceのAPIを使用することができます。

Answer 4

HashSetへのアクセスはO（1）なので、複数のスレッド間で分割すると、それ以上高速化されません。検索のファイルを分割しようとする方がコストがかかります。しかし、その効率が十分であれば、1つのスレッドが最適になります。

マシン上のすべてのコアを使用すると、プログラムの速度が遅くなることがあります。マシン上のすべてのCPUを使い切りたい場合は、マシン上のすべてのCPUを使い切るだけのスレッドプールを作成することができます。