Java 多线程-线程同步(一)

  Java中的多线程同步是一个非常大的问题,由于能力有限,所以只会介绍一些简单的知识点。由于这个方向的知识很多,所以文章会分为多个部分。

1.同步例子

  由于要讲到同步,例子肯定不能缺。同时这个例子,也用于后面的同步机制。

Bank类:

public class Bank {
    private int count = 1000;
    
    public void reduce() {
        if(count >= 100) {
            count -= 100;
            System.out.println("count = " + count);
        }
    }
    
    public int getCount() {
        return count;
    }
}

MyRunnable类:

public class MyRunnable implements Runnable{

    private Bank bank  = null;
    public MyRunnable(Bank bank) {
        this.bank = bank;
    }
    
    @Override
    public void run() {
        while(true) {
            bank.reduce();
            if(bank.getCount() <= 0) {
                break;
            }
        }
    }

}

Demol类:

public class Demo {
    public static void main(String[] args) {
        Thread threads[] = new Thread[4];
        Bank bank = new Bank();
        for(int i = 0; i < threads.length; i++) {
            threads[i] = new Thread(new MyRunnable(bank));
        }
        for(int i = 0; i < threads.length; i++) {
            threads[i].start();
        }
    }
}

  看一下这个例子,非常的简单,我们开启了4个线程,同时对Bank类里面的count属性进行减100的操作,如果count <= 0,那么线程就退出循环,进行对Bank类的count属性减100的操作。
  然后我们来看看结果:



  是不是感觉没什么问题?其实不对的,按照我们定义的规则来说,count应该是从1000一次变为0,是这样的:



  这种现象导致的原因也是非常的简单:Bank类的reduce方法不是同步,可以被多个线程执行,所以导致了在同一个时刻不同的线程获得count的值可能是不同的。

2. 锁对象

  上面看到了一个简单的多线程导致安全性的问题,从而得知,线程安全是多么的重要。在这里,将展示一个方式来保证线程同步。
  从JDK 1.5开始,Java引入了一个类--ReentrantLock类。这个类与操作系统里面的锁非常的相似。现在我们来看一下它的简单应用。
我们改写Bank的代码:

public class Bank {
    private int count = 1000;
    private ReentrantLock lock = new ReentrantLock();

    public void reduce() {
        //加锁
        lock.lock();
        if (count >= 100) {
            count -= 100;
            System.out.println("count = " + count);
        }
        //释放锁
        lock.unlock();
    }
    public int getCount() {
        return count;
    }
}

  你们会发现,我们在reduce方法里面通过ReetrantLock的lock方法进行加锁,当执行完毕之后,然后获得锁进行释放,使得其他线程能够有机会获得锁。这里需要说明的是,当那么没有获得锁的线程执行到lock.lock()方法那里的时候,会自动阻塞,直到获得锁的线程释放锁。注意分清阻塞和等待的区别
  此时我们再来看看程序运行的效果:

注意:最好是把解锁的操作放在finally里面,因为一旦在加锁和释放锁之间发生了异常,解锁不能进行执行,导致程序进入死锁的状态。

3. 条件对象

 &esmp;通常来说,会遇到这种情况,就是当前这个线程获得了锁,但是进入临界区后,发现不能进行任何的操作,相当于是当前线程获得锁是多余的。例如,在reduce方法中,之前我们是这样加锁:

    public void reduce() {
        //加锁
        lock.lock();
        if (count >= 100) {
            count -= 100;
            System.out.println("count = " + count);
        }
        //释放锁
        lock.unlock();
    }

  像这种加锁方式,有一个问题,就是当一个线程获得了一个锁对象时,发现当前的count < 100,根本就不能减,于是只能失魂落魄的退出临界区,不能对count进行任何的操作(我们此时假设有几个线程在对count进行加100的操作,有几个线程对count进行减100的操作)。
例如:

public class Bank {
    private int count = 1000;
    private ReentrantLock lock = new ReentrantLock();

    public void reduce() {
        //加锁
        lock.lock();
        if (count >= 100) {
            count -= 100;
            System.out.println("count = " + count);
        }
        //释放锁
        lock.unlock();
    }

    public void add() {
        lock.lock();
        if (count < 1000) {
            count += 10;
            System.out.println("count = " + count);
        }
        
        lock.unlock();
    }

    public int getCount() {
        return count;
    }
}

  此时我们在Bank类中加了一个add方法,用来对count的属性进行加100的操作。当一个线程调用reduce方法获得了一个锁对象时,发现count已经小于了100,因此不能对count进行任何,只有默默的退出。像这种情况,多么的不好,对这个线程多么的不公平,人家辛辛苦苦获得锁对象就这样浪费了。
  我们这样来想,假设当前的线程获得了锁对象,发现不能对count进行任何的操作,然后阻塞自己,并且释放锁,等待调用add方法的线程进行。
  想法不错,其实条件对象就是这样执行的。

public class Bank {
    private int count = 1000;
    private ReentrantLock lock = null;
    private Condition condition = null;

    public Bank() {
        lock = new ReentrantLock();
        condition = lock.newCondition();
    }

    public void reduce() {
        lock.lock();
        try {
            if (count < 100) {
                condition.await();
            } else {
                count -= 100;
                System.out.println("count = " + count);
            }
            condition.signalAll();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
    }

    public void add() {
        lock.lock();
        try {
            if (count >= 1000) {
                condition.await();
            } else {
                count += 100;
                System.out.println("count = " + count);
            }
            condition.signalAll();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
    }

    public int getCount() {
        return count;
    }
}

  我们会发现,我们在Bank类的构造方法里面先是创建了ReetrantLock类的对象,然后通过ReetrantLock类的对象创建一个Condition的对象;然后我们在看一看reduce方法,在对count进行操作之前,我们先让多个线程来获得锁,获得锁之后,如果发现count不符合要求,那么久调用condition的await方法来将自己阻塞,并且释放锁,但是需要注意的是在还有一个signalAll方法。这个方法有什么用呢?我们待会再add方法。此时reduce方法的线程如果发现count不符合要求,就将自己阻塞掉,并且释放锁,如果此时被一个add方法里面的线程获得了锁,那就可以对count进行加100的操作。操作完毕之后会调用Condition的signalAll方法唤醒之前因为Condition.await方法而阻塞掉的线程。
  经过上面的学习,我们学习了到了两种方式来使得我们的程序到达同步要求。但是这两者有什么区别呢?

1. ReetrantLock对象是用来保护代码片段的,保证任何时刻只有一个线程执行一段代码。

2. ReetrantLock对象可以管理被保护段的线程。

3. 一个ReettrantLock对象可以拥有一个或者多个Condition的对象。

4. 每个Condition对象可以管理那些获得了锁但是不能正常的运行的线程。

4. 同步方法--synchronized关键字

  我们知道,在使用ReetrantLock对象来保证程序段的同步,往往需要lock和unLock,像这种操作容易使得程序出现问题,因为如果一个程序写了lock方法,但是没有unLock方法,这个是有问题。所以ReetrantLock会使得我们的程序错误性提高,而且在使用起来又比较的麻烦。为了解决这个问题,Java推出了synchronized关键字。
  例如,我们的代码可以改成这样:

public class Bank {
    private int count = 1000;

    public synchronized void reduce() {
        if(count >= 100) {
            count -= 100;
            System.out.println("reduce " + count);
        }
    }

    public int getCount() {
        return count;
    }
}

  同时synchronized关键字还能修饰静态的方法。但是此时同步的条件不一样了,普通的方法将当前的对象作为内部锁,静态方法将当前的类作为内部锁。
  与此同时,我们synchronized关键字还能修饰代码块,但是需要我们手动设置内部锁对象,通常我们使用的当前对象。例如:

    public void reduce() {
        synchronized (this) {
            if (count >= 100) {
                count -= 100;
                System.out.println("reduce " + count + " threadId = " + Thread.currentThread().getId());
            }
        }
    }

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 194,524评论 5 460
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 81,869评论 2 371
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 141,813评论 0 320
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 52,210评论 1 263
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 61,085评论 4 355
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 46,117评论 1 272
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 36,533评论 3 381
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 35,219评论 0 253
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 39,487评论 1 290
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,582评论 2 309
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,362评论 1 326
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,218评论 3 312
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 37,589评论 3 299
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,899评论 0 17
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,176评论 1 250
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 41,503评论 2 341
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 40,707评论 2 335

推荐阅读更多精彩内容