Javaでマルチスレッドアプリケーションを開発する

Question

これは私の最初のマルチスレッドアプリケーションであれば開発できます。だから私は始めるためにいくつかの助けが必要です。

私は現在、完璧に

の作品次のJavaプログラム

1. を持って
2. （POJOの）ソース・データベースからデータを取得し、オブジェクトに変換（ターゲット・データベースからデータを取得し、オブジェクトに変換POJO）。
3. ソースオブジェクトとターゲットオブジェクトの両方を比較し、差異がある場合は、ソースデータベースの情報でターゲットデータベースを更新します。

私の要件が変更され、3つの異なるターゲットデータベース（TargetDB1、TargetDB2、TargetDB3）を使用する必要があります。それぞれに異なる接続情報があります。

私の質問は、私たちはこの

スレッド1で（スレッド1から得られた）ソースオブジェクトと比較し、TargetDB1オブジェクトを取得するソースオブジェクト

スレッド2を取得するマルチスレッドのアプリケーションにすることができていますソースオブジェクトとの相違の場合に

（スレッド1から得られた）ソースオブジェクトと比較し、TargetDB2オブジェクトを取得する糸3をTargetDB1を更新し、ソースオブジェクトとの相違の場合にTargetDB2を更新

スレッド4はTargetDB2オブジェクトを取得し、ソースオブジェクト（スレッド1から取得）と比較し、ソースオブジェクトとの違いがある場合はTargetDB2を更新します

これはマルチスレッドアプリケーションとして開発できる場合、それについて。

Answer 1

のようなBlockingQueueを使用して、ターゲットデータベースごとにワークキューを作成します。プロデューサスレッドはオブジェクトをソースデータベースから取得し、それを各作業キューに追加します。次に、ターゲット・データベースに接続されている各スレッドは、その作業キューからデキューして、独自の速度でデータベースを更新できます。

ソース・データベースのスレッドは次のようになります。

// allow only 10 outstanding objects to be in the work queue before it blocks 
queue1 = new LinkedBlockingQueue<SourceObject>(10); 
new Thread(new TargetDatabaseThread("url-to-database1", queue1)).start(); 
queue2 = new LinkedBlockingQueue<SourceObject>(10); 
new Thread(new TargetDatabaseThread("url-to-database2", queue2)).start(); 
queue3 = new LinkedBlockingQueue<SourceObject>(10); 
new Thread(new TargetDatabaseThread("url-to-database3", queue3)).start(); 
while (true) { 
    SourceObject sourceObj = getFromSourceDatabase(); 
    // this might block if you set a capacity on your queue and it was full 
    queue1.put(sourceObj); 
    queue2.put(sourceObj); 
    queue3.put(sourceObj); 
} 

ターゲット・データベース・スレッドの各その後、次のようになります。ターゲット・データベース・スレッドが必要な場合は、このモデルで

public class TargetDatabaseThread implements Runnable { 
    private final String jdbcUrl; 
    private final BlockingQueue queue; 
    private volatile boolean shutdown; 
    public TargetDatabaseThread(String jdbcUrl, BlockingQueue queue) { 
     this.jdbcUrl = jdbcUrl; 
     this.queue = queue; 
    } 
    public void run() { 
     // maybe some initialization, make database connection, etc. 
     while (!shutdown) { 
      // this would block if nothing is in the queue 
      SourceObject sourceObj = queue.take(); 
      SourceObject targetObj = 
       getObjectFromTargetDatabase(sourceObj.getId()); 
      if (updateTarget(sourceObj, targetObj)) { 
       updateMyTargetObjectInDatabase(targetObj); 
      } 
     } 
    } 
} 

一つの問題は次のようになります任意の方法でソースオブジェクトを更新します。この場合、オブジェクトを同期させる必要があります。

ブロッキングキューは容量で設定できます。これは、プロデューサがソースデータベースから読み取る方が、ターゲットデータベース作成者がデータベースを更新するよりも簡単な場合に役立ちます。ターゲットデータベースが遅いため、キューにメモリがいっぱいになることは望ましくありません。