线程同步

Question

我的程序中有两个线程，如下所示：

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语句。

有没有别的办法来解决这个问题呢？因为我的第一个线程经常依赖于第二个线程中的变量变化。

Answer 1

在CONNECTION_ESTABLISHED方法中添加volatile关键字，然后查看。

Answer 2

您正面临这样的挑战，因为您正在以非同步的方式更改静态变量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(); 
                  }
           }
     }
 }

我没有测试代码，我只是试着把概念放在一起，以便根据需要进行更改。

Answer 3

在这个特定的示例中，您可以将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;
  }
}