java线程

Posted 2020-06-30 Syria

1.1 创建线程的方式一

1. 继承Thread类

 

getName()是获取线程的名字。

执行后的效果：

 

问题： 先按照顺序运行完了张三，然后接着再按照顺序运行完李四，我们想要的效果是张三和李四做资源的争夺战，也就是先是张三然后李四，没有顺序的执行。这就证明多线程没有起到效果。

1. 需要复写run方法，把要执行的任务放在run方法中。

 

运行效果：

 

问题： 先按照顺序运行完了张三，然后接着再按照顺序运行完李四，我们想要的效果是张三和李四做资源的争夺战，也就是先是张三然后李四，没有顺序的执行。这就证明多线程没有起到效果。

 

1. 调用start()方法启动线程

 

效果：

 

达到了我们预期的效果。

线程的使用细节：

1. 线程的启动使用父类的start()方法
2. 如果线程对象直接调用run()，那么JVN不会当作线程来运行，会认为是普通的方法调用。
3. 线程的启动只能由一次，否则抛出异常
4. 可以直接创建Thread类的对象并启动该线程，但是如果没有重写run()，什么也不执行。
5. 匿名内部类的线程实现方式

1.2 线程的状态

 

创建：新创建了一个线程对象。

可运行：线程对象创建后，其他线程调用了该对象的start()方法。该状态的线程位于可运行线程池中，变得可运行，等待获取cpu的执行权。

运行：就绪状态的线程获取了CPU执行权，执行程序代码。

阻临时塞: 阻塞状态是线程因为某种原因放弃CPU使用权，暂时停止运行。直到线程进入就绪状态，才有机会转到运行状态。

死亡：线程执行完它的任务时。

1.3 常见线程的方法

Thread(String name)     初始化线程的名字

 getName()             返回线程的名字

 setName(String name)    设置线程对象名

 sleep()                 线程睡眠指定的毫秒数。

 getPriority()             返回当前线程对象的优先级   默认线程的优先级是5

 setPriority(int newPriority) 设置线程的优先级    虽然设置了线程的优先级，但是具体的实现取决于底层的操作系统的实现（最大的优先级是10 ，最小的1 ， 默认是5）。

 currentThread()      返回CPU正在执行的线程的对象

class ThreadDemo1 extends Thread { public ThreadDemo1(){    } public ThreadDemo1( String name ){    super( name ); }      public void run(){    int i = 0;    while(i < 30){   i++;       System.out.println( this.getName() + " "+ " : i = " + i);   System.out.println( Thread.currentThread().getName() + " "+ " : i = " + i);   System.out.println( Thread.currentThread() == this );   System.out.println( "getId()" + " "+ " : id = " + super.getId() );   System.out.println( "getPriority()" + " "+ " : Priority = " + super.getPriority() );    } } } class Demo3  { public static void main(String[] args) {         ThreadDemo1 th1 = new ThreadDemo1("线程1"); ThreadDemo1 th2 = new ThreadDemo1("线程2");         // 设置线程名         th1.setName( "th1" ); th2.setName( "th2" );         // 设置线程优先级  1 ~ 10 th1.setPriority( 10 ); th2.setPriority( 7 ); // 查看SUN定义的线程优先级范围 System.out.println("max : " + Thread.MAX_PRIORITY ); System.out.println("min : " + Thread.MIN_PRIORITY );         System.out.println("nor : " + Thread.NORM_PRIORITY ); th1.start(); th2.start(); System.out.println("Hello World!"); } }

 

练习：模拟卖票

 

 

存在问题：这时候启动了四个线程，那么tickets是一个成员变量，也就是在一个线程对象中都维护了属于自己的tickets属性，那么就总共存在了四份。

解决方案一：tickets使用staitc修饰，使每个线程对象都是共享一份属性。

 

解决方案2：编写一个类实现Runnable接口。

1.4 创建线程的方式二

创建线程的第二种方式.使用Runnable接口.

该类中的代码就是对线程要执行的任务的定义.

1：定义了实现Runnable接口

2：重写Runnable接口中的run方法，就是将线程运行的代码放入在run方法中

3：通过Thread类建立线程对象

4：将Runnable接口的子类对象作为实际参数，传递给Thread类构造方法

5：调用Thread类的start方法开启线程，并调用Runable接口子类run方法

为什么要将Runnable接口的子类对象传递给Thread的构造函数，因为自定义的run方法所属对象是Runnable接口的子类对象，所以要让线程去执行指定对象的run方法

package cn.itcast.gz.runnable; public class Demo1 { public static void main(String[] args) { MyRun my = new MyRun(); Thread t1 = new Thread(my); t1.start(); for (int i = 0; i < 200; i++) { System.out.println("main:" + i); } } } class MyRun implements Runnable { public void run() { for (int i = 0; i < 200; i++) { System.err.println("MyRun:" + i); } } }

 

 

理解Runnable:

Thread类可以理解为一个工人,而Runnable的实现类的对象就是这个工人的工作(通过构造方法传递).Runnable接口中只有一个方法run方法,该方法中定义的事会被新线程执行的代码.当我们把Runnable的子类对象传递给Thread的构造时,实际上就是让给Thread取得run方法,就是给了Thread一项任务.

 

 

买票例子使用Runnable接口实现

在上面的代码中故意照成线程执行完后，执行Thread.sleep（100），以让cpu让给别的线程，该方法会出现非运行时异常需要处理，这里必须进行try{}catch（）{}，因为子类不能比父类抛出更多的异常，接口定义中没有异常，实现类也不能抛出异常。

运行发现票号出现了负数，显示了同一张票被卖了4次的情况。

出现了同样的问题。如何解决？

class MyTicket implements Runnable { int tickets = 100; public void run() { while (true) { if (tickets > 0) { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "窗口@销售：" + tickets + "号票"); tickets--;   } else { System.out.println("票已卖完。。。"); break; } } } } public class Demo6 { public static void main(String[] args) { MyTicket mt = new MyTicket(); Thread t1 = new Thread(mt); Thread t2 = new Thread(mt); Thread t3 = new Thread(mt); Thread t4 = new Thread(mt); t1.start(); t2.start(); t3.start(); t4.start(); } }

2 锁对象

什么是锁对象?

每个java对象都有一个锁对象.而且只有一把钥匙.

如何创建锁对象：

    可以使用this关键字作为锁对象，也可以使用所在类的字节码文件对应的Class对象作为锁对象

1. 类名.class       

2. 对象.getClass()   

Java中的每个对象都有一个内置锁，只有当对象具有同步方法代码时，内置锁才会起作用，当进入一个同步的非静态方法时，就会自动获得与类的当前实例（this）相关的锁，该类的代码就是正在执行的代码。获得一个对象的锁也成为获取锁、锁定对象也可以称之为监视器来指我们正在获取的锁对象。

因为一个对象只有一个锁，所有如果一个线程获得了这个锁，其他线程就不能获得了，直到这个线程释放（或者返回）锁。也就是说在锁释放之前，任何其他线程都不能进入同步代码（不可以进入该对象的任何同步方法）。释放锁指的是持有该锁的线程退出同步方法，此时，其他线程可以进入该对象上的同步方法。

1：只能同步方法（代码块），不能同步变量或者类

2：每个对象只有一个锁

3：不必同步类中的所有方法，类可以同时具有同步方法和非同步方法

4：如果两个线程要执行一个类中的一个同步方法，并且他们使用的是了类的同一个实例（对象）来调用方法，那么一次只有一个线程能够执行该方法，另一个线程需要等待，直到第一个线程完成方法调用，总结就是：一个线程获得了对象的锁，其他线程不可以进入该对象的同步方法。

5：如果类同时具有同步方法和非同步方法，那么多个线程仍然可以访问该类的非同步方法。

同步会影响性能（甚至死锁），优先考虑同步代码块。

6：如果线程进入sleep（） 睡眠状态，该线程会继续持有锁，不会释放。

3 死锁

 

经典的“哲学家就餐问题”，5个哲学家吃中餐，坐在圆卓子旁。每人有5根筷子（不是5双），每两个人中间放一根，哲学家时而思考，时而进餐。每个人都需要一双筷子才能吃到东西，吃完后将筷子放回原处继续思考，如果每个人都立刻抓住自己左边的筷子，然后等待右边的筷子空出来，同时又不放下已经拿到的筷子，这样每个人都无法得到1双筷子，无法吃饭都会饿死，这种情况就会产生死锁：每个人都拥有其他人需要的资源，同时又等待其他人拥有的资源，并且每个人在获得所有需要的资源之前都不会放弃已经拥有的资源。

当多个线程完成功能需要同时获取多个共享资源的时候可能会导致死锁。

1：两个任务以相反的顺序申请两个锁，死锁就可能出现

2：线程T1获得锁L1，线程T2获得锁L2，然后T1申请获得锁L2，同时T2申请获得锁L1，此时两个线程将要永久阻塞，死锁出现

如果一个类可能发生死锁，那么并不意味着每次都会发生死锁，只是表示有可能。要避免程序中出现死锁。

例如，某个程序需要访问两个文件，当进程中的两个线程分别各锁住了一个文件，那它们都在等待对方解锁另一个文件，而这永远不会发生。

3：要避免死锁

public class DeadLock { public static void main(String[] args) { new Thread(new Runnable() { // 创建线程, 代表中国人 public void run() { synchronized ("刀叉") { // 中国人拿到了刀叉 System.out.println(Thread.currentThread().getName() + ": 你不给我筷子, 我就不给你刀叉"); try { Thread.sleep(10); } catch (InterruptedException e) { e.printStackTrace(); } synchronized ("筷子") { System.out.println(Thread.currentThread() .getName() + ": 给你刀叉"); } } } }, "中国人").start(); new Thread(new Runnable() { // 美国人 public void run() { synchronized ("筷子") { // 美国人拿到了筷子 System.out.println(Thread.currentThread().getName() + ": 你先给我刀叉, 我再给你筷子"); try { Thread.sleep(10); } catch (InterruptedException e) { e.printStackTrace(); } synchronized ("刀叉") { System.out.println(Thread.currentThread() .getName() + ": 好吧, 把筷子给你."); } } } }, "美国人").start(); } }

4 线程的通讯

线程间通信其实就是多个线程在操作同一个资源，但操作动作不同

生产者消费者

如果有多个生产者和消费者，一定要使用while循环判断标记，然后在使用notifyAll唤醒，否者容易只用notify容易出现只唤醒本方线程情况，导致程序中的所有线程都在等待。

例如：有一个数据存储空间，划分为两个部分，一部分存储人的姓名，一部分存储性别，我们开启一个线程，不停地想其中存储姓名和性别（生产者），开启另一个线程从数据存储空间中取出数据（消费者）。

由于是多线程的，就需要考虑，假如生产者刚向数据存储空间中添加了一个人名，还没有来得及添加性别，cpu就切换到了消费者的线程，消费者就会将这个人的姓名和上一个人的性别进行了输出。

还有一种情况是生产者生产了若干次数据，消费者才开始取数据，或者消费者取出数据后，没有等到消费者放入新的数据，消费者又重复的取出自己已经去过的数据。

public class Demo10 { public static void main(String[] args) { Person p = new Person(); Producer pro = new Producer(p); Consumer con = new Consumer(p); Thread t1 = new Thread(pro, "生产者"); Thread t2 = new Thread(con, "消费者"); t1.start(); t2.start(); } }   // 使用Person作为数据存储空间 class Person { String name; String gender; }   // 生产者 class Producer implements Runnable { Person p;   public Producer() {   }   public Producer(Person p) { this.p = p; }   @Override public void run() { int i = 0; while (true) { if (i % 2 == 0) { p.name = "jack"; p.gender = "man"; } else { p.name = "小丽"; p.gender = "女"; } i++; }   }   }   // 消费者 class Consumer implements Runnable { Person p;   public Consumer() {   }   public Consumer(Person p) { this.p = p; }   @Override public void run() {   while (true) { System.out.println("name:" + p.name + "---gnder:" + p.gender); } }   }

在上述代码中，Producer和Consumer 类的内部都维护了一个Person类型的p成员变量，通过构造函数进行赋值，在man方法中创建了一个Person对象，将其同时传递给Producer和Consumer对象，所以Producer和Consumer访问的是同一个Person对象。并启动了两个线程。

 

输出：

 

显然屏幕输出了小丽 man 这样的结果是出现了线程安全问题。所以需要使用synchronized来解决该问题。

 

package cn.itcast.gz.runnable;   public class Demo10 { public static void main(String[] args) { Person p = new Person(); Producer pro = new Producer(p); Consumer con = new Consumer(p); Thread t1 = new Thread(pro, "生产者"); Thread t2 = new Thread(con, "消费者"); t1.start(); t2.start(); } }   // 使用Person作为数据存储空间 class Person { String name; String gender; }   // 生产者 class Producer implements Runnable { Person p;   public Producer() {   }   public Producer(Person p) { this.p = p; }   @Override public void run() { int i = 0; while (true) { synchronized (p) { if (i % 2 == 0) { p.name = "jack"; p.gender = "man"; } else { p.name = "小丽"; p.gender = "女"; } i++; }   }   }   }   // 消费者 class Consumer implements Runnable { Person p;   public Consumer() {   }   public Consumer(Person p) { this.p = p; }   @Override public void run() {   while (true) { synchronized (p) { System.out.println("name:" + p.name + "---gnder:" + p.gender); }   } }   }

编译运行：屏幕没有再输出jack –女  或者小丽- man 这种情况了。说明我们解决了线程同步问题，但是仔细观察，生产者生产了若干次数据，消费者才开始取数据，或者消费者取出数据后，没有等到消费者放入新的数据，消费者又重复的取出自己已经去过的数据。这个问题依然存在。

升级：在Person类中添加两个方法，set和read方法并设置为synchronized的，让生产者和消费者调用这两个方法。

public class Demo10 { public static void main(String[] args) { Person p = new Person(); Producer pro = new Producer(p); Consumer con = new Consumer(p); Thread t1 = new Thread(pro, "生产者"); Thread t2 = new Thread(con, "消费者"); t1.start(); t2.start(); } }   // 使用Person作为数据存储空间 class Person { String name; String gender;     public synchronized void set(String name, String gender) { this.name = name; this.gender = gender; }   public synchronized void read() { System.out.println("name:" + this.name + "----gender:" + this.gender); }   }   // 生产者 class Producer implements Runnable { Person p;   public Producer() {   }   public Producer(Person p) { this.p = p; }   @Override public void run() { int i = 0; while (true) {   if (i % 2 == 0) { p.set("jack", "man"); } else { p.set("小丽", "女"); } i++;   }   }   }   // 消费者 class Consumer implements Runnable { Person p;   public Consumer() {   }   public Consumer(Person p) { this.p = p; }   @Override public void run() {   while (true) { p.read();   } }   }

 

需求：我们需要生产者生产一次，消费者就消费一次。然后这样有序的循环。

这就需要使用线程间的通信了。Java通过Object类的wait，notify，notifyAll这几个方法实现线程间的通信。

1.1.1. 等待唤醒机制

wait：告诉当前线程放弃执行权，并放弃监视器（锁）并进入阻塞状态，直到其他线程持有获得执行权，并持有了相同的监视器（锁）并调用notify为止。

notify：唤醒持有同一个监视器（锁）中调用wait的第一个线程，例如，餐馆有空位置后，等候就餐最久的顾客最先入座。注意：被唤醒的线程是进入了可运行状态。等待cpu执行权。

notifyAll：唤醒持有同一监视器中调用wait的所有的线程。

 

如何解决生产者和消费者的问题？

可以通过设置一个标记，表示数据的（存储空间的状态）例如，当消费者读取了（消费了一次）一次数据之后可以将标记改为false，当生产者生产了一个数据，将标记改为true。

，也就是只有标记为true的时候，消费者才能取走数据，标记为false时候生产者才生产数据。

代码实现：

package cn.itcast.gz.runnable;   public class Demo10 { public static void main(String[] args) { Person p = new Person(); Producer pro = new Producer(p); Consumer con = new Consumer(p); Thread t1 = new Thread(pro, "生产者"); Thread t2 = new Thread(con, "消费者"); t1.start(); t2.start(); } }   // 使用Person作为数据存储空间 class Person { String name; String gender; boolean flag = false;   public synchronized void set(String name, String gender) { if (flag) { try { wait(); } catch (InterruptedException e) {   e.printStackTrace(); } } this.name = name; this.gender = gender; flag = true; notify(); }   public synchronized void read() { if (!flag) { try { wait(); } catch (InterruptedException e) {   e.printStackTrace(); } } System.out.println("name:" + this.name + "----gender:" + this.gender); flag = false; notify(); }   }   // 生产者 class Producer implements Runnable { Person p;   public Producer() {   }   public Producer(Person p) { this.p = p; }   @Override public void run() { int i = 0; while (true) {   if (i % 2 == 0) { p.set("jack", "man"); } else { p.set("小丽", "女"); } i++;   }   }   }   // 消费者 class Consumer implements Runnable { Person p;   public Consumer() {   }   public Consumer(Person p) { this.p = p; }   @Override public void run() {   while (true) { p.read();   } }   }

 

线程间通信其实就是多个线程在操作同一个资源，但操作动作不同，wait，notify（），notifyAll()都使用在同步中，因为要对持有监视器（锁）的线程操作，所以要使用在同步中，因为只有同步才具有锁。

为什么这些方法定义在Object类中

因为这些方法在操作线程时，都必须要标识他们所操作线程持有的锁，只有同一个锁上的被等待线程，可以被统一锁上notify唤醒，不可以对不同锁中的线程进行唤醒，就是等待和唤醒必须是同一个锁。而锁由于可以使任意对象，所以可以被任意对象调用的方法定义在Object类中

wait() 和 sleep()有什么区别？

wait():释放资源，释放锁。是Object的方法

sleep():释放资源，不释放锁。是Thread的方法

定义了notify为什么还要定义notifyAll，因为只用notify容易出现只唤醒本方线程情况，导致程序中的所有线程都在等待。

 

2. 线程生命周期

任何事物都是生命周期，线程也是，

1. 正常终止  当线程的run()执行完毕，线程死亡。

2. 使用标记停止线程

注意：Stop方法已过时，就不能再使用这个方法。

如何使用标记停止线程停止线程。

开启多线程运行，运行代码通常是循环结构，只要控制住循环，就可以让run方法结束，线程就结束。

 

class StopThread implements Runnable { public boolean tag = true; @Override public void run() { int i = 0;   while (tag) { i++; System.out.println(Thread.currentThread().getName() + "i:" + i); } } } public class Demo8 { public static void main(String[] args) { StopThread st = new StopThread(); Thread th = new Thread(st, "线程1"); th.start(); for (int i = 0; i < 100; i++) { if (i == 50) { System.out.println("main i:" + i); st.tag = false; } } } }

上述案例中定义了一个计数器i，用来控制main方法（主线程）的循环打印次数，在i到50这段时间内，两个线程交替执行，当计数器变为50，程序将标记改为false，也就是终止了线程1的while循环，run方法结束，线程1也随之结束。注意：当计数器i变为50的，将标记改为false的时候，cpu不一定马上回到线程1，所以线程1并不会马上终止。

3. 后台线程

后台线程：就是隐藏起来一直在默默运行的线程，直到进程结束。

 实现：

      setDaemon(boolean on)

 特点：

当所有的非后台线程结束时，程序也就终止了同时还会杀死进程中的所有后台线程，也就是说，只要有非后台线程还在运行，程序就不会终止，执行main方法的主线程就是一个非后台线程。

必须在启动线程之前（调用start方法之前）调用setDaemon（true）方法，才可以把该线程设置为后台线程。

一旦main（）执行完毕，那么程序就会终止，JVM也就退出了。

可以使用isDaemon() 测试该线程是否为后台线程（守护线程）。

该案例：开启了一个qq检测升级的后台线程，通过while真循环进行不停检测，当计数器变为100的时候，表示检测完毕，提示是否更新，线程同时结束。

为了验证，当非后台线程结束时，后台线程是否终止，故意让该后台线程睡眠一会。发现只要main线程执行完毕，后台线程也就随之消亡了。

class QQUpdate implements Runnable { int i = 0;   @Override public void run() { while (true) {   System.out.println(Thread.currentThread().getName() + " 检测是否有可用更新"); i++; try { Thread.sleep(10); } catch (InterruptedException e) {   e.printStackTrace(); } if (i == 100) { System.out.println("有可用更新，是否升级？"); break; } } } } public class Demo9 { public static void main(String[] args) { QQUpdate qq = new QQUpdate(); Thread th = new Thread(qq, "qqupdate"); th.setDaemon(true); th.start(); System.out.println(th.isDaemon()); System.out.println("hello world"); } }

     

Thread的join方法

当A线程执行到了B线程Join方法时A就会等待，等B线程都执行完A才会执行，Join可以用来临时加入线程执行

本案例，启动了一个JoinThread线程，main（主线程）进行for循环，当计数器为50时，让JoinThread，通过join方法，加入到主线程中，发现只有JoinThread线程执行完，主线程才会执行完毕.

可以刻意让JoinThread线程sleep，如果JoinThread没有调用join方法，那么肯定是主线程执行完毕，但是由于JoinThread线程加入到了main线程，必须等JoinThread执行完毕主线程才能继续执行。

class JoinThread implements Runnable {   @Override public void run() { int i = 0; while (i < 300) { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + " i:" + i); i++; } } }   public class Demo10 { public static void main(String[] args) throws InterruptedException { JoinThread jt = new JoinThread(); Thread th = new Thread(jt, "one"); th.start(); int i = 0; while (i < 200) { if (i == 100) { th.join(); } System.err.println(Thread.currentThread().getName() + " i:" + i); i++;   } } }

上述程序用到了Thread类中的join方法，即th.join语句，作用是将th对应的线程合并到嗲用th.join语句的线程中，main方法的线程中计数器到达100之前，main线程和one线程是交替执行的。在main线程中的计数器到达100后，只有one线程执行，也就是one线程此时被加进了mian线程中，one线程不执行完，main线程会一直等待

带参数的join方法是指定合并时间，有纳秒和毫秒级别。