什么是线程?
线程(thread)是一个程序内部的一条执行路径。
我们之前启动程序执行后,main方法的执行其实就是一条单独的执行路径。
程序中如果只有一条执行路径,那么这个程序就是单线程的程序。
多线程是什么?
多线程是指从软硬件上实现多条执行流程的技术。
多线程的创建
Thread类
方式一:继承Thread类
1、定义一个子类MyThread继承线程类java.lang.Thread,重写run()方法。
2、创建MyThread类的对象。
3、调用线程对象的start()方法启动线程(启动后还是执行run方法的)。
/**目标:多线程的创建方式一:继承Thread类实现。*/
public class ThreadDemo1 {public static void main(String[] args) {// 3、new一个新线程对象Thread t = new MyThread();// 4、调用start方法启动线程(执行的还是run方法)t.start();for (int i = 0; i < 5; i++) {System.out.println("主线程执行输出:" + i);}}
}/**1、定义一个线程类继承Thread类*/
class MyThread extends Thread{public MyThread(){super();}/**2、重写run方法,里面是定义线程以后要干啥*/@Overridepublic void run() {for (int i = 0; i < 5; i++) {System.out.println("子线程执行输出:" + i);}}
}
方式二:实现Runnable接口
1、定义一个线程任务类MyRunnable实现Runnable接口,重写run()方法。
2、创建MyRunnable任务对象。
3、把MyRunnable任务对象交给Thread处理。
4、调用线程对象的start()方法启动线程。
**目标:学会线程的创建方式二,理解它的优缺点。*/
public class ThreadDemo2 {public static void main(String[] args) {// 3、创建一个任务对象Runnable target = new MyRunnable();// 4、把任务对象交给Thread处理Thread t = new Thread(target);// Thread t = new Thread(target, "1号");// 5、启动线程t.start();for (int i = 0; i < 10; i++) {System.out.println("主线程执行输出:" + i);}}
}/**1、定义一个线程任务类 实现Runnable接口*/
class MyRunnable implements Runnable {/**2、重写run方法,定义线程的执行任务的*/@Overridepublic void run() {for (int i = 0; i < 10; i++) {System.out.println("子线程执行输出:" + i);}}
}
也可以用匿名内部类形式
/**目标:学会线程的创建方式二(匿名内部类方式实现,语法形式)*/
public class ThreadDemo2Other {public static void main(String[] args) {Runnable target = new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {System.out.println("子线程1执行输出:" + i);}}};Thread t = new Thread(target);t.start();new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {System.out.println("子线程2执行输出:" + i);}}}).start();new Thread(() -> {for (int i = 0; i < 10; i++) {System.out.println("子线程3执行输出:" + i);}}).start();for (int i = 0; i < 10; i++) {System.out.println("主线程执行输出:" + i);}}
}
方式三:利用Callable、FutureTask接口实现(JDK 5.0新增)
1、得到任务对象
定义类实现Callable接口,重写call方法,封装要做的事情。
用FutureTask把Callable对象封装成线程任务对象。
2、把线程任务对象交给Thread处理。
3、调用Thread的start方法启动线程,执行任务 。
4、线程执行完毕后,通过FutureTask的get方法去获取任务执行的结果。
FutureTask的API
示例
/**目标:学会线程的创建方式三:实现Callable接口,结合FutureTask完成。*/
public class ThreadDemo3 {public static void main(String[] args) {// 3、创建Callable任务对象Callable<String> call = new MyCallable(100);// 4、把Callable任务对象 交给 FutureTask 对象// FutureTask对象的作用1: 是Runnable的对象(实现了Runnable接口),可以交给Thread了// FutureTask对象的作用2: 可以在线程执行完毕之后通过调用其get方法得到线程执行完成的结果FutureTask<String> f1 = new FutureTask<>(call);// 5、交给线程处理Thread t1 = new Thread(f1);// 6、启动线程t1.start();Callable<String> call2 = new MyCallable(200);FutureTask<String> f2 = new FutureTask<>(call2);Thread t2 = new Thread(f2);t2.start();try {// 如果f1任务没有执行完毕,这里的代码会等待,直到线程1跑完才提取结果。String rs1 = f1.get();System.out.println("第一个结果:" + rs1);} catch (Exception e) {e.printStackTrace();}try {// 如果f2任务没有执行完毕,这里的代码会等待,直到线程2跑完才提取结果。String rs2 = f2.get();System.out.println("第二个结果:" + rs2);} catch (Exception e) {e.printStackTrace();}}
}/**1、定义一个任务类 实现Callable接口 应该申明线程任务执行完毕后的结果的数据类型*/
class MyCallable implements Callable<String>{private int n;public MyCallable(int n) {this.n = n;}/**2、重写call方法(任务方法)*/@Overridepublic String call() throws Exception {int sum = 0;for (int i = 1; i <= n ; i++) {sum += i;}return "子线程执行的结果是:" + sum;}
}
3种方式对比
注意事项
1、为什么不直接调用run方法,而是调用start启动线程?
直接调用run方法会当成普通方法执行,此时相当于还是单线程执行。 只有调用start方法才是启动一个新的线程执行,(看start源码)start方法会把线程加入线程组,每个线程都有机会交给cpu执行,这时线程的run方法会被自动调用,每个线程都有可能还没执行完就被中断从而让cpu执行其他线程,。
2、为什么把主线程任务放在子线程之后?
如果把主线程任务放在子线程之前,那么主线程一定是先跑完的,相当于是一个单线程的效果了。