码迷,mamicode.com
首页 > 编程语言 > 详细

java的多线程

时间:2019-07-02 21:36:36      阅读:172      评论:0      收藏:0      [点我收藏+]

标签:img   err   http   str   ++   概念   卖出   count   图片   

线程的概念等之前讲过,今天主要写线程的安全性问题

1.实现多线程的两种方式:

package com.zs.service;

/**
 * 通过继承实现多线程,
 * 优点:代码简单
 * 缺点: 单继承的局限性
 */
public class Demo1 extends Thread {
    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            System.out.println(Thread.currentThread().getName() + "第" + i + "次");
        }
    }

    public static void main(String[] args) {
        Demo1 demo1 = new Demo1();
        Demo1 demo2 = new Demo1();
        demo1.start();
        demo2.start();
    }
}
package com.zs.service;

/**
 * 实现继承的第二种方式,通过实现runnable接口实现多线程
 * 优点:避免了单继承的局限行
 * 缺点:代码比较复杂
 *
 * 通常使用这种方式实现多线程,代码的可拓展性更强
 */
public class Demo2 implements Runnable {
    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            System.out.println(Thread.currentThread().getName() + "第" + i + "次");
        }
    }

    public static void main(String[] args) {
        Demo2 demo2 = new Demo2();
        Thread t1 = new Thread(demo2);
        Thread t2 = new Thread(demo2);
        t1.start();
        t2.start();
    }
}

多线程主要有以上两种实现方式,一般使用接口的方式实现多线程,因为代码的拓展性强,下面我们来通过一个案例来理解线程的同步锁:

模拟一个网络买车票,多个窗口一块卖同一批车票,因此是多线程,下面通过代码实现:

package com.zs.service;

public class ChePiao implements Runnable {
    private int count=50;//定义总共有50张票
    private int num = 0;//卖出第几张票
    @Override
    public void run() {
        while (true) {
            if (count <= 0) {
                break;
            }
            count--;
            num++;
            /*模拟网络延迟*/
            if (count == 10) {
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println(Thread.currentThread().getName()+"卖出第"+num+"张票");
        }
    }

    public static void main(String[] args) {
        ChePiao chePiao = new ChePiao();
        Thread t1 = new Thread(chePiao, "窗口1");
        Thread t2 = new Thread(chePiao, "窗口2");
        Thread t3 = new Thread(chePiao, "窗口3");
        t1.start();
        t2.start();
        t3.start();
    }
}

运行结果:

技术图片

会出现这种情况,这是不正确的,因为同一张票只能出售一次,因此就需要引入同步机制

package com.zs.service;

public class ChePiao implements Runnable {
    private int count=50;//定义总共有50张票
    private int num = 0;//卖出第几张票
    @Override
    public void run() {

        while (true) {
            /**
             * synchronized 同步锁,将可能产生数据安全的代码锁起来,这样被锁起来的代码就会编程单线程
             * 两种解决同步安全问题:
             * 1.同步代码块
             * 2.同步方法  public synchronized void fun(){..}在返回值前加同步锁
             */
            synchronized (this) {
                if (count <= 0) {
                    break;
                }
                count--;
                num++;
                System.out.println(Thread.currentThread().getName()+"卖出第"+num+"张票");
            }
            /*模拟网络延迟*/
            if (count == 10) {
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

        }
    }

    public static void main(String[] args) {
        ChePiao chePiao = new ChePiao();
        Thread t1 = new Thread(chePiao, "窗口1");
        Thread t2 = new Thread(chePiao, "窗口2");
        Thread t3 = new Thread(chePiao, "窗口3");
        t1.start();
        t2.start();
        t3.start();
    }
}

 

java的多线程

标签:img   err   http   str   ++   概念   卖出   count   图片   

原文地址:https://www.cnblogs.com/Zs-book1/p/11123057.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!