一、理解多线程的创立
从这里开始,咱们来理解线程的创立,个别有以下多种形式等创立形式
- 继承Thread类
- 实现Runnable接口
继承Thread类和实现Runnable接口,这两种形式能够说是中规中矩的,也是咱们用的比拟多的创立线程的形式。
- 匿名外部类的形式
咱们也能够应用匿名外部类的形式继承Thread类和实现Runnable接口的实现另外一种形式创立
- 带返回值的线程
在run()办法中没有方法去抛出更多的异样,而且没有返回值。那么咱们就心愿有一个可能抛出异样并且带返回值的这么一种线程,这就提供了第四种创立线程的形式
- 定时器(quartz)
其实定时器也相当于是其中的一个线程,也是属于创立线程的一种形式
- 线程池的实现
还有就是咱们都晓得的能够通过线程池的形式来创立线程
- Lambda表达式实现
在JDK8中,新增了一个十分弱小的一个Lambda表达式,那么,就能够通过这个表达式能够实现多线程这种对咱们汇合的操作、对咱们的数据流的操作等等
二、从源码上了解线程的创立
第一种形式就是继承Thread类的形式,咱们说万物皆对象,那么线程也能够是一个对象
//继承Threadclass Demo1 extends Thread{ }
这时咱们的Demo1就是线程类的子类,那么调用实例的线程的启动办法就能够启动线程了
那么线程执行什么活呢?其实就是在线程外面定义过的一个run()办法,咱们来看一下
public class Thread implements Runnable { @Override public void run() { if (target != null) { target.run(); } } //省略其余关键性代码......}
这个run()办法的代码体十分的简略,这个办法是须要咱们去重写的。
咱们先重写run()办法,等会在提一提源码中的这个run()办法中的代码的意思
class Demo1 extends Thread{ @Override public void run() { System.out.println("线程执行起来了....."); }}
咱们刚刚说到线程也能够是一个对象,那么Thread都有哪些属性和行为呢?咱们能够通过源码来简略的看一下
这时咱们在运行线程,就能够打印出线程的名称来看看是哪一个线程了
class Demo1 extends Thread{ @Override public void run() { System.out.println(getName()+"线程执行起来了....."); } public static void main(String[] args) { Demo1 demo1 = new Demo1(); demo1.start(); }}//运行后果如下:Thread-0 线程执行起来了.....
咱们并没有给它指定名字,它是如何叫做Thread-0呢?咱们来看一下源码
public class Thread implements Runnable { public Thread() {init(null, null, "Thread-" + nextThreadNum(), 0);} public Thread(Runnable target) {init(null, target, "Thread-" + nextThreadNum(), 0);} Thread(Runnable target, AccessControlContext acc) {init(null, target, "Thread-" + nextThreadNum(), 0, acc, false);} public Thread(ThreadGroup group, Runnable target) {init(group, target, "Thread-" + nextThreadNum(), 0);} public Thread(String name) {init(null, null, name, 0);} public Thread(ThreadGroup group, String name) {init(group, null, name, 0);} public Thread(Runnable target, String name) {init(null, target, name, 0);} public Thread(ThreadGroup group, Runnable target, String name) {init(group, target, name, 0);} public Thread(ThreadGroup group, Runnable target, String name,long stackSize) {init(group, target, name, stackSize);} //省略其余关键性代码......}
通过观察Thread的构造方法,咱们发现能够给定指定的线程名字进行初始化
class Demo1 extends Thread{ public Demo1(String name) { super(name); } @Override public void run() { System.out.println(getName()+"线程执行起来了....."); } public static void main(String[] args) { Demo1 demo1 = new Demo1("first-thrade"); demo1.start(); }}//运行后果如下:first-thrade线程执行起来了.....
咱们不论应用哪种构造方法,在创立Thread类的时候构造方法外面都有一个进行初始化的过程。
public class Thread implements Runnable { public Thread(String name) { init(null, null, name, 0); } //省略其余关键性代码......}
咱们来剖析看看这个init()办法外面有什么?做了些什么事件?
public class Thread implements Runnable { //ThreadGroup 线程组 作用:用于对线程进行分组的 private void init(ThreadGroup g, Runnable target, String name,long stackSize) { init(g, target, name, stackSize, null, true); } //省略其余关键性代码......}
这个办法外面有很多的参数,第一个参数是线程组,这个线程组是干什么的呢?其实就是用于对线程进行分组的。
咱们能够来看一下这个线程组都有哪些办法?
其实线程组它是一种树状构造,能够这么了解,比如说这是以后一个顶层的线程组
那么这个顶层线程组外面,上面能够接着放线程组,也能够放线程
总之它就是一层一层的往下走,依照面向对象的思维形式,它会有它的名字,以及获取它的上一级下一级等性能
接下来咱们看init办法()第二个参数是Runnable,也就是能够指定一个线程工作。
public class Thread implements Runnable { //target 线程 作用:能够指定一个线程工作 private void init(ThreadGroup g, Runnable target, String name,long stackSize) { init(g, target, name, stackSize, null, true); } //省略其余关键性代码......}
第三个参数就是线程的名字,当咱们的初始化时没有给予名字时
public class Thread implements Runnable { public Thread() { init(null, null, "Thread-" + nextThreadNum(), 0); } //省略其余关键性代码......}
发现会调用的是Thread- nextThreadNum(),对线程进行编号
public class Thread implements Runnable { //用于主动编号匿名线程 private static int threadInitNumber; private static synchronized int nextThreadNum() { return threadInitNumber++; } //省略其余关键性代码......}
这也就是为什么咱们没有给予线程名字,它为什么叫做Thread-0的起因
第四个参数是stackSize,那么,这个参数又是什么呢?咱们看一下到底是什么?
public class Thread implements Runnable { /* * The requested stack size for this thread, or 0 if the creator did * not specify a stack size. It is up to the VM to do whatever it * likes with this number; some VMs will ignore it. */ private long stackSize; //省略其余关键性代码......}
就是开发Thread类的这个人,他也不晓得stackSize到底是干什么用的,它是为虚拟机做一些事件,做一些什么事件呢?
做一些虚拟机想干的事件,就是说stackSize指定了之后,虚拟机能够通过stackSize做一些虚拟机想做的事件。
当然了,很多的虚拟机是疏忽stackSize的。所以,咱们也不须要关stackSize这个参数了
三、对于线程的Daemon
Daemon是用来干什么的呢?咱们称它叫做守护线程,或者说它是一个反对型线程,它是干什么的呢?
它次要是作用在程序中后盾调用做一些支持性工作,就比如说垃圾回收线程吧,它就扔在后盾在后盾本人默默的去做一些事,当程序执行结束的时候,它即便执行不结束那么它仍然会跟着退出
class Demo1 extends Thread{ public Demo1(String name) { super(name); } @Override public void run() { while (true){ System.out.println(getName()+"线程执行起来了....."); } } public static void main(String[] args) { Demo1 demo1 = new Demo1("first-thrade"); demo1.setDaemon(true); demo1.start(); }}
咱们当初把线程的Daemon设置为True,使以后线程是反对型线程,这样即便这个线程的线程工作没有执行结束,当主线程执行结束之后,那么这个线程也仍然会被退出
四、从源码上了解线程的中断
比如说咱们想让一个线程执行一段时间之后,咱们不想让它再执行了,咱们让它中断掉怎么办呢?咱们在Thread里看看有什么办法
咱们看到这里有三个办法,interrupt()、interrupted()、isInterrupted()。
public class Thread implements Runnable { //给以后线程标记中断标记 public void interrupt() { if (this != Thread.currentThread()) checkAccess(); synchronized (blockerLock) { Interruptible b = blocker; if (b != null) { interrupt0(); // Just to set the interrupt flag b.interrupt(this); return; } } interrupt0(); } //省略其余关键性代码......}
public class Thread implements Runnable { //返回以后线程中断标记并将它重置 public static boolean interrupted() { return currentThread().isInterrupted(true); } //省略其余关键性代码......}
public class Thread implements Runnable { //返回以后线程中断标记但不重置 public boolean isInterrupted() { return isInterrupted(false); } //省略其余关键性代码......}
那么接下来咱们创立两个线程,同时让一个线程中断,看看是什么成果
class Demo1 extends Thread{ public Demo1(String name) { super(name); } @Override public void run() { while (true){ System.out.println(getName()+"线程执行起来了....."); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } }}
public static void main(String[] args) { Demo1 demo1 = new Demo1("xiaoming-thrade"); Demo1 demo2 = new Demo1("xiaohong-thrade"); //启动两个线程 demo1.start(); demo2.start(); //让xiaoming线程中断 demo1.interrupt();}运行后果如下:xiaohong-thrade线程执行起来了.....xiaoming-thrade线程执行起来了.....xiaoming-thrade线程执行起来了.....java.lang.InterruptedException: sleep interrupted at java.lang.Thread.sleep(Native Method) at Demo1.run(thread.java:57)xiaohong-thrade线程执行起来了.....
咱们发现执行出错了,然而前面仍然在执行。那么这是怎么回事呢?
这就须要咱们本人去解决,咱们写代码须要解决中断这种状态
class Demo1 extends Thread{ public Demo1(String name) { super(name); } @Override public void run() { while (!interrupted()){ System.out.println(getName()+"线程执行起来了....."); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } }}
public static void main(String[] args) { Demo1 demo1 = new Demo1("xiaoming-thrade"); Demo1 demo2 = new Demo1("xiaohong-thrade"); //启动两个线程 demo1.start(); demo2.start(); //让xiaoming线程标记中断标记 demo1.interrupt();}运行后果如下:xiaohong-thrade线程执行起来了.....xiaohong-thrade线程执行起来了.....xiaohong-thrade线程执行起来了.....xiaohong-thrade线程执行起来了.....
这时咱们的run办法里的while条件是调用interrupted(),它会返回以后线程中断标记并且重置它,这样以后线程不是中断标记的话就去执行
那么咱们之前调用了demo1.interrupt()之后,会将demo1的中断标记批改为"是中断"
咱们能够调用isInterrupted()办法去查看demo1的中断标记,你会发现会返回为true
class Demo1 extends Thread{ public Demo1(String name) { super(name); } @Override public void run() { System.out.println(getName() +"线程的中断标记为"+isInterrupted()); while (!interrupted()){ System.out.println(getName()+"线程执行起来了....."); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } }}运行后果如下:xiaoming-thrade线程的中断标记为truexiaohong-thrade线程的中断标记为falsexiaohong-thrade线程执行起来了.....xiaohong-thrade线程执行起来了.....xiaohong-thrade线程执行起来了.....
若咱们调用interrupted办法来查看以后线程中断标记,那么就会重置这就会满足while条件
class Demo1 extends Thread{ public Demo1(String name) { super(name); } @Override public void run() { System.out.println(getName() +"线程的中断标记为"+interrupted()); while (!interrupted()){ System.out.println(getName() +"线程的中断标记为"+interrupted()); System.out.println(getName()+"线程执行起来了....."); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } }}运行后果如下:xiaoming-thrade线程的中断标记为truexiaoming-thrade线程的中断标记为falsexiaoming-thrade线程执行起来了.....xiaohong-thrade线程的中断标记为falsexiaohong-thrade线程的中断标记为falsexiaohong-thrade线程执行起来了.....
这时就会造成demo1线程重置后,一样能够运行起来实现输入
参考资料
龙果学院:并发编程原理与实战(叶子猿老师)