您的位置:首页 > 编程语言 > Java开发

有关java并发程序同步概念的全部意义

2016-04-18 22:52 357 查看

问题

最近拜读Effective java的时候,在并发部分看到了一段类似这样的代码

private static boolean stopRequested;
public static void main(String[] args) throws InterruptedException
{
Thread thred = new Thread(new Runnable()
{
@Override
public void run()
{
int i= 0;
while(!stopRequested)
{
i++;
}
}
});
thred.start();
TimeUnit.SECONDS.sleep(1);
stopRequested = true;
}


运行结果是什么?运行1s后退出?

刚看到这段代码的时候我也以为这样,但是结果是thread线程的while循环根本不会停止,线程不会结束。(jdk 1.7以上版本结果,1.6并不会一直循环)

同步的意义

同步可以保证在同一时刻,只有一个线程可以进入临界区执行代码,而初学者都把同步的概念仅仅当成了一种互斥方式,正确使用同步只是为了保证所有方法看到的对象都会处于一直状态。

然而除此之外,在Effective Java中是这样介绍的

如果没有同步,一个线程的变化就不能被其他线程看到,同步不仅可以阻止一个线程看到对象处于不一致的状态中,还可以保证进入同步方法或者同步代码块的每个线程,都看到由同一个锁保护的之前所有的修改效果。

根据这段描述也不难关联到一个java的关键字volatile,它可以保证任何一个线程在读取该关键字修饰的对象或变量时,都可以看到最近刚刚被写入的值。

解决

这个问题的原因在与虚拟机对代码的优化,由于没有同步,所以不能确定thread线程何时可以得到主线程对stopRequested的值所做的改变,虚拟机将

while(!done)
i++


修改为

if(!done)
while(true)
i++;


运行的时候只有一次访问done,之后就不再访问了。

既然这样,就可以用同步告诉虚拟机,这个线程什么时候访问stopRequested的值。

比如,用volatile修饰stopRequested变量

private static volatile boolean stopRequested;
public static void main(String[] args) throws InterruptedException
{
Thread thred = new Thread(new Runnable()
{
@Override
public void run()
{
int i= 0;
while(!stopRequested)
{
i++;
}
Sysout.out.print("end");
}
});
thred.start();
TimeUnit.SECONDS.sleep(1);
stopRequested = true;
}


在经过接近1s的停顿后打印出end



当然也可以对获取变量和修改变量加上同步

private static boolean stopRequested;

private static void setStopRequested(boolean stop)
{
stopRequested = stop;
}

private static synchronized boolean getStopRequested()
{
return stopRequested;
}
public static void main(String[] args) throws InterruptedException
{
Thread backgroundThred = new Thread(new Runnable()
{
@Override
public void run()
{
int i= 0;
while(!getStopRequested())
{
i++;
}
System.out.println("end");
}
});
backgroundThred.start();
TimeUnit.SECONDS.sleep(1);
setStopRequested(true);
}


结果不放了。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: