多线程访问同一个可变变量,需增加同步机制
说明:根据Java Language Specification中对Java内存模型的定义, JVM中存在一个主内存(Java Heap Memory),Java中所有变量都储存在主存中,对于所有线程都是共享的。每个线程都有自己的工作内存(WorkingMemory),工作内存中保存的是主存中某些变量的拷贝,线程对所有变量的操作都是在工作内存中进行,线程之间无法相互直接访问,变量传递均需要通过主存完成。根据上述内存模型的定义,要在多个线程间安全的同步共享数据就必须使用锁机制,将某线程中更新的数据从其工作内存中刷新至主内存,并确保其他线程从主内存获取此数据更新后的值再使用。
示例:
不好:下面的代码中,没有对可变数据stopRequested的访问做同步。程序期望在一秒钟后线程能停止。但在用java 1.6的server模式运行此程序(Java –server StopThread)时,程序陷入死循环,不能结束
publicclassStopThread
{
privatestaticbooleanstopRequested;
publicstaticvoid main(String[] args) throws InterruptedException
{
Thread backgroundThread = new Thread(new Runnable()
{
publicvoid run()
{
int i= 0;
while(!stopRequested)
{
i++;
}
}
});
backgroundThread.start();
TimeUnit.SECONDS.sleep(1);
stopRequested = true;
}
}
增加了synchronized同步机制后,程序就能正确地在1秒后终止。另一个方案是在变量前增加 volatile关键字。
publicclassStopThread
{
privatestaticbooleanstopRequested;
privatestaticsynchronizedvoidrequestStop()
{
stopRequested = true;
}
privatestaticsynchronizedboolean isStopRequested()
{
returnstopRequested;
}
publicstaticvoid main(String[] args) throws InterruptedException
{
Thread backgroundThread = new Thread(new Runnable()
{
publicvoid run()
{
int i= 0;
while(!stopRequested())
{
i++;
}
}
});
backgroundThread.start();
TimeUnit.SECONDS.sleep(1);
requestStop();
}
}