线程池概念介绍

news2024/11/15 2:10:37

一、初始化线程的四种方式

1.继承Thread

2.实现Runnable

3.实现Callable接口+FutureTask

4.线程池:两种主要初始化方式Executors.newFixedThreadPool()或new ThreadPoolExecutor()

方式1和方式2:主进程无法获取线程的运算结果。

方式3:主进程可以获取运算结果，但是不利于控制服务器中的线程资源，从而导致服务器资源耗尽。

方式4:线程池性能稳定，可以获取执行结果、捕获异常。但是在业务复杂情况下，一个异步调用可能会依赖于另一个异步调用的执行结果。

简单实用方式

继承Thread

public class ThreadTest {
    public static void main(String[] args) {
        System.out.printf("启动开始----");
        /**
         *  继承Thread
         */
        Thread thread = new Thread01();
        // 启动线程
        thread.start();
        System.out.printf("启动结束----")
    }

    static class Thread01 extends Thread {
        @Override
        public void run() {
            System.out.printf("当前线程："+Thread.currentThread().getId());
            int i = 10/2;
            System.out.printf("运行结果"+i);
        }
    }
    
}

运行结果：

实现Runnable

public class ThreadTest {
    public static void main(String[] args) {
        System.out.printf("启动开始----");
        /**
         *  实现Runnable
         */
        Runnable01 runnable01 = new Runnable01();
        new Thread(runnable01).start();
        System.out.printf("启动结束----");

    }

   
    static class Runnable01 implements Runnable{
        @Override
        public void run() {
            System.out.printf("当前线程："+Thread.currentThread().getId());
            int i = 10/2;
            System.out.printf("运行结果"+i);

        }
    }
   
}

运行结果：

实现Callable接口+FutureTask

如果使用：futureTask.get()获取结果，将会变成阻塞等待。

public class ThreadTest {
    public static void main(String[] args) {
        System.out.printf("启动开始----");

        /**
         * 实现Callable接口+FutureTask
         */
        // FutureTask底层继承Runnable
        FutureTask futureTask = new FutureTask<>(new Callable01());
        new Thread(futureTask).start();
        // 可以会获取返回值，如果获取将会变成阻塞等待
        try {
            // 等待整个线程执行完成，获取返回结果（阻塞等待）
            Object o = futureTask.get();
            System.out.printf("o----"+o);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        System.out.printf("启动结束----");

    }

    static class Callable01 implements Callable<Integer> {


        @Override
        public Integer call() throws Exception {
            System.out.printf("当前线程："+Thread.currentThread().getId());
            int i = 10/2;
            System.out.printf("运行结果"+i);
            return i;
        }
    }
}

运行结果：

线程池

public class ThreadTest {
// 创建线程池
    static ExecutorService service = Executors.newFixedThreadPool(10);
    public static void main(String[] args) {
        System.out.printf("启动开始----");
        /**
         * 线程池
         */
        // submit提交线程有返回参数，execute执行没有返回参数
        service.execute(new Runnable01());

    }
    static class Runnable01 implements Runnable{
        @Override
        public void run() {
            System.out.printf("当前线程："+Thread.currentThread().getId());
            int i = 10/2;
            System.out.printf("运行结果"+i);

        }
    }
}