マルチスレッドプログラムの2番目のスレッドの作成に問題があります

Question

2つのスレッドを持つマルチスレッドプログラムを作成しようとしています。最初のコマンドは "新しい"コマンドのプロンプトが表示された後にランダムアクセスファイルを更新し、2番目のコマンドは "new"または "end"コマンドを受け付けて最初のスレッドに送信します。私は、セマフォーによって制御されるキューを使用したいと思っていました。私はちょうど他のスレッドを関連付ける方法を知らない。一方のスレッドはユーザーコマンドから文字列を生成してキューに挿入し、もう一方のスレッドは文字列をキューから取り出してダイレクトアクセスファイルに書き込みます。スレッドの開始方法を教えてもらえますか？

package multi_threaded_producer_consumer; 
import java.util.concurrent.Semaphore; 

public class MTQueue { 

    private Semaphore sem = new Semaphore(1); 
    private java.util.Queue<String> statQ; 

    public static void main(String[] args) { 

    } 

    public MTQueue(){ 
     statQ = new java.util.LinkedList<String>(); 
    } 

    public void MTPut(String qe) { 
     try { 
      sem.acquire(); 
      statQ.offer(qe); 
     } catch(InterruptedException ex) { 

     } finally { 
      sem.release(); 
     } 
    } 

    public String MTGet() { 
     String retVal = new String(); 
     try { 
      sem.acquire(); 
      retVal = statQ.poll(); 
     } catch(InterruptedException ex) { 

     } finally { 
      sem.release(); 
     } 
     return retVal; 
    } 

} 

Answer 1

誰でもスレッドが開始する方法でチャイムを助けることができますか？

確かに。基本スレッドでは、スレッドを実行するためにRunnableクラスを作成する必要があります。ここにはgood tutorial on the subjectがあります。ここで

は、あなたの生産のためのコードの例です：いいえためにあなたのコードに関する他のコメントの

// queue must be final for the Runnable classes to use it 
final MTQUeue queue = new MTQueue(); 
... 
// create a new producer thread and start it 
new Thread(new Runnable() { 
    public void run() { 
     queue.MTPut("new"); 
     queue.MTPut("end"); 
    } 
}).start(); 
... 
// create a new consumer thread and start it 
new Thread(new Runnable() { 
    public void run() { 
     System.out.println("Got command: " + queue.MTGet()); 
     System.out.println("Got command: " + queue.MTGet()); 
    } 
}).start(); 

カップル：

• 私は、これは学術的なプロジェクトであると仮定します。それ以外の場合はLinkedBlockingQueueをご覧ください。
• MTPut()およびMTGet()のメソッドは、おそらくちょうどput()とget()です。 MTはクラス名にあります。
• statQ.offer(...)は、おそらくstatQ.add(...)です。 offer()メソッドは、限られたキューに対してのみ使用されます。 LinkedQueueはそれらの1つではありません。
• String retVal = new String();new String()は不要で削除できます。実際にreturn statQ.poll();を実行し、retValを持っていない可能性があります。

• キャッチInterruptedException exそれを無視することは、実際には悪いことです。

  } catch(InterruptedException ex) { 
      // always a good pattern to re-interrupt the current thread 
      Thread.currentThread().interrupt(); 
      // since the thread was interrupted we should return or something 
      return;