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.

在第二个线程中，Boolean CONNECTION_ESTABLISHED设置为true某个点。如果我不在第一个线程中使用Thread.sleep(1000)，在第二个线程CONNECTION_ESTABLISHED中设置为之后true我不会在第一个线程中输入相关if语句。

还有其他方法吗？因为我的第一个线程通常会依赖于第二个线程中的变量变化。

4

3 回答 3

1

在方法中添加volatile关键字CONNECTION_ESTABLISHED并查看。

于 2013-06-01T07:37:00.980 回答
0

您正面临挑战，因为您正在以非同步方式更改静态变量 CONNECTION_ESTABLISHED 并且您没有使用等待通知机制进行线程通信。使用等待通知应该对您有所帮助。创建一个用于等待通知的对象并使用如下代码

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，它将按预期工作，其他线程将在下次访问该变量时看到更改。

但是，我会警告您不要将 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 回答