线程同步

 对访问同一个资源的多个线程进行协调的过程,就叫线程同步  用一个简单的例子讲述线程同步问题:  小明账户里有3000元钱,他拿存折去银行取2000,银行的机器首先判断账户里的钱够不够2000,判断够。与此同时,小明的老婆拿着小明的银行卡去了另一家银行取钱,也取2000,判断也够,小明的老婆取出来了,账户里的钱变为了1000,这时小明这边的机器已经判断过足够了,所以小明也取出了2000,账户的钱变为1000。最终的结果就是,小明和他老婆分别取了2000块钱,账户还剩1000。  解决这个问题的方法也很简单,只要规定,访问统一账户的人同时只能有一个。就比方说,两台电脑不能同时登陆同一个qq  下面先看一个示例

public class TestSync implements Runnable{
    Timer timer = new Timer();
    public static void main(String[] args) {
        TestSync test = new TestSync();
        Thread t1 = new Thread(test);
        Thread t2 = new Thread(test);
        t1.setName("t1");
        t2.setName("t2");
        t1.start();
        t2.start();
    }
    public void run() {
        timer.add(Thread.currentThread().getName());
    }
}
class Timer{
    private static int num = 0;
    public void add(String name) {
        num++;
        try {
            Thread.sleep(1);
        }catch(InterruptedException e) {}
        System.out.println(name + ",你是第" + num + "个使用timer的线程");
    }
}

 首先用一个内存图分析一下整个程序:

 输出结果为:

t1,你是第2个使用timer的线程
t2,你是第2个使用timer的线程

 分析一下这个程序的执行:  首先一个线程在执行add方法的过程中,执行了一次num++,此时num的值是1,然后当前线程sleep,另一个线程开始执行add方法,又执行了一次num++,此时num的值是2,然后这个线程sleep。上一个线程sleep结束了,输出,num的值就是2,然后另一个线程sleep也结束了,输出,num的值也是2  其实这就跟前面的取钱例子一样,解决办法就是给add方法加一把锁,让他同时只能有一个线程访问,不论当前线程是否睡眠,只有当访问add方法的线程结束了,才能允许另一个线程访问

public class TestSync implements Runnable{
    Timer timer = new Timer();
    public static void main(String[] args) {
        TestSync test = new TestSync();
        Thread t1 = new Thread(test);
        Thread t2 = new Thread(test);
        t1.setName("t1");
        t2.setName("t2");
        t1.start();
        t2.start();
    }
    public void run() {
        timer.add(Thread.currentThread().getName());
    }
}
class Timer{
    private static int num = 0;
    public void add(String name) {
        synchronized (this) {
            num++;
            try {
                Thread.sleep(1);
            }catch(InterruptedException e) {}
            System.out.println(name + ",你是第" + num + "个使用timer的线程");
        }
    }
}

 另一种写法,直接给方法加锁

public class TestDeadLock implements Runnable{
    public int flag = 1;
    static Object o1 = new Object(),o2 = new Object();
    public void run() {
        System.out.println("flag = " + flag);
        if(flag == 1) {
            synchronized(o1) {
                try {
                    Thread.sleep(500);
                }catch(InterruptedException e) {
                    e.printStackTrace();
                }
                synchronized(o2) {
                    System.out.println("1");
                }
            }
        }
        if(flag == 0) {
            synchronized(o2) {
                try {
                    Thread.sleep(500);
                }catch(Exception e) {
                    e.printStackTrace();
                }
                synchronized(o1) {
                    System.out.println("2");
                }
            }
        }
    }
    public static void main(String[] args) {
        TestDeadLock td1 = new TestDeadLock();
        TestDeadLock td2 = new TestDeadLock();
        td1.flag = 1;
        td2.flag = 0;
        Thread t1 = new Thread(td1);
        Thread t2 = new Thread(td2);
        t1.start();
        t2.start();
    }
}

&esmp;运行结果如下图:

 首先分别给两个线程内的flag变量分别赋值为1和0,那么他们就会分别执行对应的if语句。对于flag = 1来说,它先锁住o1,让它sleep500毫秒,只要再锁住o2,就可以打印1了;对于flag = 0来说,它先锁住o2,让它sleep500毫秒,只要再锁住o1,就可以打印2了,所以他们分别锁住一个线程对象,等待另一个线程对象,但是他们永远不可能锁住另一个线程对象了,所以程序进入了死锁

一道面试题

public class TT implements Runnable{
    static int b = 100;
    public synchronized static void m1() throws InterruptedException {
        b = 1000;
        Thread.sleep(5000);
        System.out.println("b = " + b);
    }
    public static void m2() {
        b = 2000;
        System.out.println(b);
    }
    public void run() {
        try {
            m1();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) throws InterruptedException {
        TT tt = new TT();
        Thread t = new Thread(tt);
        t.start();
        Thread.sleep(1000);
        tt.m2();
    }
}

 上述程序输出结果是什么?  正确答案:

2000
b = 2000

面试题变形

public class TT implements Runnable{
    static int b = 100;
    public synchronized static void m1() throws InterruptedException {
        b = 1000;
        Thread.sleep(5000);
        System.out.println("b = " + b);
    }
    public synchronized static void m2() throws InterruptedException {
        Thread.sleep(2500);
        b = 2000;
    }
    public void run() {
        try {
            m1();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) throws InterruptedException {
        TT tt = new TT();
        Thread t = new Thread(tt);
        t.start();
        tt.m2();
    }
}

 最后结果是:b = 1000  用一段文字解释一下上面两个问题,首先是第一个程序,m1方法带锁,m2不带锁,主线程中创建线程t,t调用m1方法,将b的值改为1000,然后sleep,此时主线程也在继续执行,调用了m2方法,将b的值改为2000,打印b。随后m1继续执行,打印的b当然就是2000  对于第二个程序,m1和m2两个方法都带锁,那么这两个方法就不能被同时访问,同时只能有一个方法在执行,另一个方法会等待。首先t开始,然后主线程继续执行m2,此时m1是不能会被执行的,因为两个方法都带锁,m2执行完,b的值被改为2000,然后执行m1,b的值又被改为1000

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏抠抠空间

Django 2.0 新款URL配置详解

Django2.0发布后,很多人都拥抱变化,加入了2的行列。 但是和1.11相比,2.0在url的使用方面发生了很大的变化,下面介绍一下:

2905
来自专栏java一日一条

教你在Java接口中定义方法

接下来,SimpleTimeClient类实现了TimeClient接口,具体代码如下:

1222
来自专栏java一日一条

教你在Java接口中定义方法

基本上所有的Java教程都会告诉我们Java接口的方法都是public、abstract类型的,没有方法体的。

911
来自专栏小樱的经验随笔

UVa 11461 - Square Numbers【数学,暴力】

题目链接:https://uva.onlinejudge.org/index.php?option=com_onlinejudge&Itemid=8&page=...

3265
来自专栏贾老师の博客

Makefile 变量定义

1496
来自专栏数据结构与算法

1750:全排列

1750:全排列 查看 提交 统计 提问 总时间限制: 1000ms 内存限制: 65536kB描述 给定一个由不同的小写字母组成的字符串,输出这个字符串的所...

37714
来自专栏LuckQI

一文了解Mongodb使用的语法

在使用数据库之前,我们需要先了解下其基本的数据结构类型。防止我们出现类型不匹配的问题。 支持的数据类型补充的是本人在开发中经常使用的。还有更多的数据类型可以参考...

1686
来自专栏菜鸟致敬

【Lua菜鸟②】数据类型

Lua是动态类型语言,变量不要类型定义,只需要为变量赋值。 值可以存储在变量中,作为参数传递或结果返回。(我想了想python) -- 用来单行注释 --[[...

4496
来自专栏mySoul

Java静态方法和实例方法 java中的数组作为形参传入

启动一个Java程序的时候,会诞生一个虚拟机实例,当程序关闭退出时,该实例会消失。

2081
来自专栏Golang语言社区

Golang语言的函数调用信息

函数的调用信息是程序中比较重要运行期信息, 在很多场合都会用到(比如调试或日志). Go语言 runtime 包的 runtime.Caller / runti...

5626

扫码关注云+社区

领取腾讯云代金券