欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

effective java同步访问共享的可变数据

程序员文章站 2022-07-12 18:21:30
...

关键字synchronized可以保证同一时刻,只有一个线程可以执行某一个方法,或者某一个代码块。
同步的意思:
1、当一个对象被一个线程修改的时候,可以阻止另一个线程观察到对象内部不一致的状态;
2、同步不仅可以组织一个线程看到对象处于不一致的状态,还可以保证进入同步方法或者同步代码块的每个线程,都看到由同一个锁保护的之前所有的修改效果。
考虑下面这个阻止一个线程妨碍另一个线程的任务。java的类库中提供了Thread.stop方法,但是这个方法是不安全的,会导致数据遭到破坏,建议使用线程轮询(poll)一个boolean域,另一个线程设置这个boolean域

public class StopThread {
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的值:"+i);
                    }
                }
            });
            backgroundThread.start();
            TimeUnit.SECONDS.sleep(1);
            StopRequested =true;
        }
}

以上这个程序会永远执行下去,因为没有同步,无法保证后台进程可以看到stopRequested值得改变,虚拟机将代码:

while(!stopRequested){
    i++;
    System.out.println("输出i的值:"+i);
}

转变成了:

if(!stopRequested){
    while(true){
        i++;
        System.out.println("输出i的值:"+i);
    }
}

这样一来,永远不会看到stopRequested的改变,必须让线程看到变量的改变才好。

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的值:"+i);
                }
            }
        });
        backgroundThread.start();
        TimeUnit.SECONDS.sleep(5);
        requestStop();
    }
}

解决这个问题的最好办法就是尽量避免在线程间共享可变数据,将可变数据限制在单线程中,让线程短时间修改一个对象,并与其他线程共享,,如果多个线程共享可变数据,那么读写都需要进行同步。