暂无图片
暂无图片
暂无图片
暂无图片
暂无图片

线程同步

秃头架构 2018-09-03
209

Java多线程-线程同步


前面的实例已经设计到同步问题:


上代码:

package com.java1234.chap09.sec05;

public class Thread1 implements Runnable{

    private int baoZi=1;

    private String threadName;

    public Thread1(String threadName) {
        super();
        this.threadName = threadName;
    }

    @Override
    public void run() {
        while(baoZi<=10){
            System.out.println(threadName+" 吃第"+baoZi+"个包子");
            baoZi++;
        }
    }

    public static void main(String[] args) {
        Thread1 t1=new Thread1("超级张三线程");

        Thread t11=new Thread(t1);
        Thread t12=new Thread(t1);
        Thread t13=new Thread(t1);

        t11.start();
        t12.start();
        t13.start();
    }

}

超级张三线程 吃第1个包子运行输出:

超级张三线程 吃第1个包子

超级张三线程 吃第2个包子

超级张三线程 吃第3个包子

超级张三线程 吃第4个包子

超级张三线程 吃第5个包子

超级张三线程 吃第6个包子

超级张三线程 吃第7个包子

超级张三线程 吃第8个包子

超级张三线程 吃第9个包子

超级张三线程 吃第11个包子

超级张三线程 吃第8个包子


我们发现 会有多个线程同时进入方法吃包子的情况发生,这时候,就引入了线程同步。可以给方法加同步,同一时刻,只允许一个线程进入方法;

关键字 synchronized

package com.java1234.chap09.sec05;

public class Thread3 implements Runnable{

    private int baoZi=1;

    private String threadName;

    public Thread3(String threadName) {
        super();
        this.threadName = threadName;
    }

    @Override
    public synchronized void run() {
        while(baoZi<=10){
            System.out.println(threadName+" 吃第"+baoZi+"个包子");
            baoZi++;
        }
    }

    public static void main(String[] args) {
        Thread3 t1=new Thread3("超级张三线程");

        Thread t11=new Thread(t1);
        Thread t12=new Thread(t1);
        Thread t13=new Thread(t1);

        t11.start();
        t12.start();
        t13.start();
    }

}

超级张三线程 吃第1个包子运行输出:

超级张三线程 吃第2个包子

超级张三线程 吃第3个包子

超级张三线程 吃第4个包子

超级张三线程 吃第5个包子

超级张三线程 吃第6个包子

超级张三线程 吃第7个包子

超级张三线程 吃第8个包子

超级张三线程 吃第9个包子

超级张三线程 吃第10个包子


也可以用同步块:

package com.java1234.chap09.sec05;

public class Thread4 implements Runnable{

    private int baoZi=1;

    private String threadName;

    public Thread4(String threadName) {
        super();
        this.threadName = threadName;
    }

    @Override
    public void run() {
        /**
         * 同步块
         */

        synchronized (this) {
            while(baoZi<=10){
                System.out.println(threadName+" 吃第"+baoZi+"个包子");
                baoZi++;
            }
        }
    }

    public static void main(String[] args) {
        Thread4 t1=new Thread4("超级张三线程");

        Thread t11=new Thread(t1);
        Thread t12=new Thread(t1);
        Thread t13=new Thread(t1);

        t11.start();
        t12.start();
        t13.start();
    }

}



文章转载自秃头架构,如果涉嫌侵权,请发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。

评论