三种创建方式

  • 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接口

  1. 实现Callable接口，需要返回值类型
  2. 重写call方法，需要抛出异常
  3. 创建目标对象
  4. 创建执行服务：ExecutorService ser=Executors.newFixedThreadPool(1);
  5. 提交执行：Future result1=ser.submit(t1);
  6. 获取执行：boolean r1=result1.get();
  7. 关闭服务：ser.shutdownNow();
//线程创建方式三：实现callable接口/*callabel的好处1，可以定义返回值2，可以抛出异常 */public class CallableTest implements Callable {        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 r1=ser.submit(t1);            Future r2=ser.submit(t2);            Future 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方法出现问题");        }    }}