-
1.Thread 与 Runnable 的关系
-
2.Callable实现多线程
-
3.线程运行状态
====================================================================================
经过一系列的分析之后可以发现,在多线程的实现过程之中已经有了两种做法:Thread类、Runnable接口,如果从代码结构本身来讲,使用Runnable是最方便的,因为其可以避免单继承的局限,同时也可以更好的进行功能的扩充。
但是从结构上也需要来观察Thread与Runnable的联系,打开Thread类的定义:
public class Thread extends Object implements Runnable{}
发现现在Thread类也是Runnable接口的子类,那么在之前继承Thread类的时候实际上覆写的还是Runnable接口的run()方法,于是此时来观察一下程序的类结构。
多线程的设计之中,使用了代理设计模式的结构,用户自定义的线程主体类只是负责项目核心功能的实现,而所有的辅助实现全部交由Thread类来处理。
可以查看一下Thread类里面的信息,来阅读下面:
在进行Thread启动多线程的时候调用的是start()方法,而后找到的是run()方法,当通过Thread类的构造方法传递了一个Runnable接口对象的时候,那么该接口对象将被Thread类中的target属性所保存,在start()方法执行的时候会调用Thread类中的run()方法,而这个run()方法去调用Runnable接口子类被覆写过得run()方法。
多线程开发的本质实质上是在于多个线程可以进行同一资源的抢占,那么Thread主要描述的是线程,而资源的描述是通过Runnable完成的。
案例:利用卖票程序来实现多个线程的资源并发访问:
class MyThread implements Runnable { //接口实现类必须实现接口的所有方法,如果要实现部分的话,可以用抽象类
private int ticket = 5;
@Override
public void run() {
for (int x = 0; x < 100; x++) {
if (this.ticket > 0)
System.out.println("卖票。ticket = " + this.ticket–);
}
}
}
public class test {
public static void main(String[] args) {
MyThread mt = new MyThread();
new Thread(mt).start();
new Thread(mt).start();
new Thread(mt).start();
}
}
通过内存分析图来分析本程序的执行结构:
============================================================================
从最传统的开发来讲,如果要进行多线程的实现肯定依靠的就是Runnable,但是Runnable接口有一个缺点:当线程执行完毕之后无法获取一个返回值,所以从JDK1.5之后就提出了一个新的线程实现接口:ja
va.util.comcurrent.Callable接口,首先来观察这个接口的定义:
@FunctionalInterface
public interface Callable{
public V call() throws Exception ;
}
可以发现Callable定义的时候可以设置一个泛型,此泛型的类型就是返回数据的类型,这样的好处是可以避免向下转型所带来的安全隐患。
看下面的代码时,一定要多看看接口和类的源码(ctrl+鼠标左键)
import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;
class MyThread implements Callable {
@Override
public String call() throws Exception {
for (int x = 0; x < 10; x++) {
System.out.println("**************** 线程执行,x = " + x);
}
return “线程执行完毕”;
}
}
public class test {
public static void main(String[] args) throws Exception {
ystem.out.println("**************** 线程执行,x = " + x);
}
return “线程执行完毕”;
}
}
public class test {
public static void main(String[] args) throws Exception {