线程创建

三种创建方式

  • 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<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方法出现问题");
        }
    }
}

热门相关:冉冉心动   欲望之屋2   半仙   锦乡里   管家:妻子的朋友