三种创建方式
- Thread class 继承Thread类
- Runnable接口 实现Runnable接口
- Callable接口 实现Callable接口
Thread
-
自定义线程类继承Thread类
-
重写run()方法，编写线程执行体
-
创建线程对象，调用start()方法启动线程
//创建线程方式一：继承Thread类，重写run()方法，调用start开启线程 //注意，线程开启不一定立即执行，由cpu调度执行 public class TestThread extends Thread{ @Override public void run() { //run方法线程体 for (int i = 0; i < 20; i++) { System.out.println("我在Run方法"+i); } } public static void main(String[] args) { //main线程，主线程 //创建一个线程对象 TestThread testThread=new TestThread(); //调用start()方法开启线程 testThread.start(); for (int i = 0; i < 20; i++) { System.out.println("我在main函数中"+i); } } }注：run方法只是普通方法，直接调用程序只是先后分别执行两个方法，而start方法，相当于另外开辟一个子线程，去执行run方法，也就是实现两个方法同时进行；
编译部分结果：(每次结果都可能不一样)
我在main函数中0 我在Run方法0 我在main函数中1 我在Run方法1 我在main函数中2 我在Run方法2 我在main函数中3 我在Run方法3 我在Run方法4 我在Run方法5 我在Run方法6 我在main函数中4 我在Run方法7 我在main函数中5 我在main函数中6 我在Run方法8 ...........
实现Runable
- 定义MyRunnable类实现Runnable接口
- 实现run()方法，编写线程执行体
- 创建线程对象，调用start()方法启动线程
//实现线程方式2：实现runnable接口，重写run方法，执行线程需要丢入runnable接口实现类，调用start方法
public class TestThread2 implements Runnable{
@Override
public void run() {
//run方法线程体
for (int i = 0; i < 20; i++) {
System.out.println("我在Run方法"+i);
}
}
public static void main(String[] args) {
//main线程，主线程
//创建runnable接口的实现类对象
TestThread2 testThread2=new TestThread2();
//创建线程对象，通过线程对象来开启我们的线程，代理
// Thread thread=new Thread(testThread2);
// thread.start();
new Thread(testThread2).start();
for (int i = 0; i < 20; i++) {
System.out.println("我在main函数中"+i);
}
}
}
编译部分结果：(每次结果都可能不一样)
我在main函数中0
我在Run方法0
我在main函数中1
我在Run方法1
我在main函数中2
我在Run方法2
我在main函数中3
我在Run方法3
我在Run方法4
我在main函数中4
........
小结
继承thread
- 子类继承Thread类具备多线程能力
- 启动线程：子类对象.start()
- 不建议使用：避免OOP单继承
实现Runnable接口
- 实现接口Runnable具备多线程能力
- 启动线程：传入目标对象+Thread对象.start()
- 推荐使用：避免单继承局限性，灵活性，方便同一个对象被多个线程使用
实现Callable接口
- 实现Callable接口，需要返回值类型
- 重写call方法，需要抛出异常
- 创建目标对象
- 创建执行服务：ExecutorService ser=Executors.newFixedThreadPool(1);
- 提交执行：Future
result1=ser.submit(t1); - 获取执行：boolean r1=result1.get();
- 关闭服务：ser.shutdownNow();
//线程创建方式三：实现callable接口
/*
callabel的好处
1，可以定义返回值
2，可以抛出异常
*/
public class CallableTest implements Callable<Boolean> {
private String url;//下载网络图片地址
private String name; //保存的文件名
public CallableTest(String url, String name) {
this.name = name;
this.url = url;
}
//下载图片线程的执行体
public Boolean call() {
WebDownLoder webDownLoder = new WebDownLoder();
webDownLoder.downLoader(url, name);
System.out.println("下载好文件" + name);
return true;
}
public static void main(String[] args) throws ExecutionException, InterruptedException {
CallableTest t1=new CallableTest("https://img0.baidu.com/it/u=1435639120,2241364006&fm=253&fmt=auto&app=138&f=JPEG?w=800&h=500","1.jpg");
CallableTest t2=new CallableTest("https://img1.baidu.com/it/u=2559867097,3726275945&fm=253&fmt=auto&app=138&f=JPEG?w=1333&h=500","2.jpg");
CallableTest t3=new CallableTest("https://img0.baidu.com/it/u=2503372846,402736698&fm=253&fmt=auto&app=120&f=JPEG?w=1280&h=800","3.jpg");
//1. 创建执行服务：
ExecutorService ser= Executors.newFixedThreadPool(3);
//2. 提交执行：
Future<Boolean> r1=ser.submit(t1);
Future<Boolean> r2=ser.submit(t2);
Future<Boolean> r3=ser.submit(t3);
//3. 获取执行：
boolean rs1=r1.get();
boolean rs2=r2.get();
boolean rs3=r3.get();
//4. 关闭服务：
ser.shutdownNow();
}
}
//下载器
class WebDownLoder{
//下载方法
public void downLoader(String url, String name) {
try {
FileUtils.copyURLToFile(new URL(url), new File(name));
} catch (IOException e) {
e.printStackTrace();
System.out.println("IO异常，downLoader方法出现问题");
}
}
}
