深入同步访问共享的可变数据分析
更新时间：2013年06月04日 17:58:47 作者：
本篇文章是对同步访问共享的可变数据进行了详细的分析介绍，需要的朋友参考下
如果对共享的可变数据的访问不能同步，其后果非常可怕，即使这个变量是原子可读写的。
下面考虑一个线程同步方面的问题。对于线程同步，Java类库提供了Thread.stop的方法，但是这个方法并不值得提倡，因为它本质上是不安全的。使用轮询（Polling）的方式会更好，例如下面这段程序。
import java.util.concurrent.TimeUnit;
public class StopThread {
/**
* @param args
*/
private static boolean stopRequested;
public static void main(String[] args)
throws InterruptedException{
Thread backgroundThread = new Thread(new Runnable() {
@Override
public void run() {
int i = 0;
while(!stopRequested){
i++;
System.out.println(i);
}
}
});
backgroundThread.start();
TimeUnit.SECONDS.sleep(1);
stopRequested = true;
}
}
你可能会认为这个程序在运行大约一秒后，由于主线程把stopRequested设成了true，使得后台的新线程停止，其实不然，因为后台线程看不到这个值的变化，所以会一直无线循环下去，这就是没有对数据进行同步的后果。因此让我们用同步的方式来实现这个任务。
import java.util.concurrent.TimeUnit;
public class StopThread {
/**
* @param args
*/
private static boolean stopRequested;
private static synchronized void requestStop(){
stopRequested = true;
}
private static synchronized boolean stopRequested(){
return stopRequested;
}
public static void main(String[] args)
throws InterruptedException{
Thread backgroundThread = new Thread(new Runnable() {
@Override
public void run() {
int i = 0;
while(!stopRequested()){
i++;
System.out.println(i);
}
}
});
backgroundThread.start();
TimeUnit.SECONDS.sleep(1);
requestStop();
}
}
这样就实现了数据的同步，值得注意的是，写方法（requestStop）和读方法（stopRequested）都需要被同步，否则仍然不是真正意义上的同步。
另外，我们可以使用volatile这个变量修饰符来更加简单地完成同步任务。
import java.util.concurrent.TimeUnit;
public class StopThread {
/**
* @param args
*/
private static volatile boolean stopRequested;
public static void main(String[] args)
throws InterruptedException{
Thread backgroundThread = new Thread(new Runnable() {
@Override
public void run() {
int i = 0;
while(!stopRequested){
i++;
System.out.println(i);
}
}
});
backgroundThread.start();
TimeUnit.SECONDS.sleep(1);
stopRequested = true;
}
}
下面考虑一个线程同步方面的问题。对于线程同步，Java类库提供了Thread.stop的方法，但是这个方法并不值得提倡，因为它本质上是不安全的。使用轮询（Polling）的方式会更好，例如下面这段程序。
复制代码 代码如下:
import java.util.concurrent.TimeUnit;
public class StopThread {
/**
* @param args
*/
private static boolean stopRequested;
public static void main(String[] args)
throws InterruptedException{
Thread backgroundThread = new Thread(new Runnable() {
@Override
public void run() {
int i = 0;
while(!stopRequested){
i++;
System.out.println(i);
}
}
});
backgroundThread.start();
TimeUnit.SECONDS.sleep(1);
stopRequested = true;
}
}
你可能会认为这个程序在运行大约一秒后，由于主线程把stopRequested设成了true，使得后台的新线程停止，其实不然，因为后台线程看不到这个值的变化，所以会一直无线循环下去，这就是没有对数据进行同步的后果。因此让我们用同步的方式来实现这个任务。
复制代码 代码如下:
import java.util.concurrent.TimeUnit;
public class StopThread {
/**
* @param args
*/
private static boolean stopRequested;
private static synchronized void requestStop(){
stopRequested = true;
}
private static synchronized boolean stopRequested(){
return stopRequested;
}
public static void main(String[] args)
throws InterruptedException{
Thread backgroundThread = new Thread(new Runnable() {
@Override
public void run() {
int i = 0;
while(!stopRequested()){
i++;
System.out.println(i);
}
}
});
backgroundThread.start();
TimeUnit.SECONDS.sleep(1);
requestStop();
}
}
这样就实现了数据的同步，值得注意的是，写方法（requestStop）和读方法（stopRequested）都需要被同步，否则仍然不是真正意义上的同步。
另外，我们可以使用volatile这个变量修饰符来更加简单地完成同步任务。
复制代码 代码如下:
import java.util.concurrent.TimeUnit;
public class StopThread {
/**
* @param args
*/
private static volatile boolean stopRequested;
public static void main(String[] args)
throws InterruptedException{
Thread backgroundThread = new Thread(new Runnable() {
@Override
public void run() {
int i = 0;
while(!stopRequested){
i++;
System.out.println(i);
}
}
});
backgroundThread.start();
TimeUnit.SECONDS.sleep(1);
stopRequested = true;
}
}
相关文章
这篇文章主要给大家介绍了关于Java文件、文件夹权限修改的两种方法，文中通过示例代码介绍的非常详细，对大家学习或者使用Java具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧2019-08-08
最近的一个项目中涉及到了支付业务,其中用到了微信支付和支付宝支付,本文就来介绍一下Java实现微信支付的项目实践,具有一定的参考价值,感兴趣的可以了解一下2023-10-10
这篇文章主要介绍了JVM中四种GC算法案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下2021-09-09
这篇文章主要介绍了java字符串所有操作方法汇总,需要的朋友可以参考下,在实际的编程中,我们经常需要对字符串进行各种操作,例如连接、截取、替换等,本文将按类别介绍一些Java字符串的常用方法,帮助读者更好地理解和使用2023-11-11
随着业务发展，单体系统逐渐无法满足业务的需求，分布式架构逐渐成为大型互联网平台首选。伴随而来的问题是，本地事务方案已经无法满足，分布式事务相关规范和框架应运而生。本文主要介绍Seata的实现原理2021-06-06
这篇文章主要为大家详细介绍了基于Java开发实现ATM系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-08-08
这篇文章主要介绍了Spring中IOC和AOP的核心组成架构详解,本文是对Spring的2大核心功能——IoC和AOP 的总结提炼,并增加了环境profile和条件化bean的内容,篇幅较短,更像是一个大纲,或者思维导图,需要的朋友可以参考下2023-08-08
这篇文章主要为大家详细介绍了shiro之INI配置的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-09-09
这篇文章主要介绍了使用@Value值注入及配置文件组件扫描方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-07-07
这篇文章主要介绍了解决mapper接口无法映射mapper.xml的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-06-06
最新评论