2

次のように、プログラムに2つのスレッドがあります。

class SendThread implements Runnable {
     public void run(){
           Thread.sleep(1000);

           while (true){    
                if (CONNECTION_ESTABLISHED){
                    // code here
                }
           } 
     } 
 } 

class ReceiveThread implements Runnable {
     public void run(){


           while (true){    
                // code here
                CONNECTION_ESTABLISHED = true;  

           }
     }
 }

として定義CONNECTION_ESTABLISHEDしましたstatic Boolean。

2 番目のスレッドでは、特定の時点でBoolean CONNECTION_ESTABLISHEDが設定されます。true1 番目のスレッドで使用しない場合、2 番目のThread.sleep(1000)スレッドで afterCONNECTION_ESTABLISHEDが設定されている場合、1番目のスレッドでは関連するステートメントをtrue入力しません。if

これを回避する別の方法はありますか？私の最初のスレッドは、多くの場合、2 番目のスレッドの変数の変更に依存するためです。

4

3 に答える 3

1

メソッドにvolatileキーワードを追加して参照してください。CONNECTION_ESTABLISHED

于 2013-06-01T07:37:00.980 に答える
0

非同期の方法で静的変数 CONNECTION_ESTABLISHED を変更しており、スレッド通信に待機通知メカニズムを使用していないため、課題に直面しています。待機通知を使用すると役立ちます。wait-notify に使用するオブジェクトを作成し、以下のコードを使用します

class SendThread implements Runnable {
     public void run(){
           Thread.sleep(1000);

           while (true){  
                synchronized(object)  {
                    object.wait();
                    if (CONNECTION_ESTABLISHED){
                       // code here

                    }
                }
           } 
     } 
 } 

class ReceiveThread implements Runnable {
     public void run(){


           while (true){   
                synchronized(object)  {
                   // code here
                   CONNECTION_ESTABLISHED = true;  
                   object.notify(); 
                  }
           }
     }
 }

私はコードをテストしていません。概念を入れようとしただけなので、必要に応じて変更してください。

于 2013-06-01T07:38:15.053 に答える
0

この特定の例では、CONNECTION_ESTABLISHED ブール値を揮発性としてマークすることができ、それは期待どおりに機能し、他のスレッドは次に変数にアクセスするときに変更を認識します。

ただし、最も単純なケース (単一変数の更新) を除いて、volatile を使用しないように警告します。原子性を提供しないため、更新中に複数の割り当てを行う必要がある場合、必要な保証は提供されません。これには、実際にはメモリ モデル レベルでの読み取り/変更/書き込みの 3 つの操作であるインクリメント/デクリメントが含まれるため、適切な同期が必要です。

その場合、読み取りと書き込みの両方で同期ブロックを使用する必要があります。

private final Object lock = new Object();

private int shared1;
private int shared2;

public void write(int var1, int var2)
{
  sychronized (lock)
  {
    shared1 = var1;
    shared2 = var2;
  }
}

public int readSum()
{
  sychronized (lock)
  {
    int total = shared1 + shared2;
    return total;
  }
}
于 2013-06-01T07:39:23.167 に答える