Java线程池的应用

Love The Way You Lie 2021-09-29 14:16 281阅读 0赞

**一 使用Future与Callable来计算斐波那契数列**

1 代码

import java.util.concurrent.*;
    public class FutureCallableDemo
    {
        static long fibonacci(long n)
        {
            if (n == 1 ||n == 2)
                return 1;
            else
                return fibonacci(n - 1) + fibonacci(n - 2);
        }        
        public static void main( String[] args) throws Exception
        {
            Callable<Long> task = () -> fibonacci(30);
            ExecutorService executor = Executors.newFixedThreadPool(1);
            Future<Long> future = executor.submit(task);
            System.out.println("计算第10个斐波那契级数，过会来取...") ;          
            while (future.isDone() == false)
            {
                System.out.println("忙别的去吧，结果还在计算中...") ;
            }
            System.out.printf("计算完毕，第10个斐波那契级数是:%d %n", future.get()) ;
        }  
    }

2 运行

计算第10个斐波那契级数，过会来取...
    忙别的去吧，结果还在计算中...
    忙别的去吧，结果还在计算中...
    忙别的去吧，结果还在计算中...
    忙别的去吧，结果还在计算中...
    忙别的去吧，结果还在计算中...
    ......
    忙别的去吧，结果还在计算中...
    计算完毕，第10个斐波那契级数是:832040

**二 线程池模拟工人做工**

1 代码

import java.util.concurrent.Executors;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    class Task implements Runnable
    {
        private String name;
        public Task(String name)
        {
            this.name = name;
        }    
        public String getName() {
            return name;
        }
        @Override
        public void run()
        {
            try
            {
                Long duration = (long) (Math.random() * 100);
                System.out.println("正在做工中，执行者 : " + name);
                TimeUnit.SECONDS.sleep(duration);
            }
            catch (InterruptedException e)
            {
                e.printStackTrace();
            }
        }
    }
    public class BasicThreadPoolExecutorExample
    {
        public static void main(String[] args)
        {
            ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newCachedThreadPool();
            for (int i = 0; i <= 5; i++)
            {
                Task task = new Task("Task " + i);
                System.out.println("新任务添加成功 : " + task.getName());
                executor.execute(task);
            }
            executor.shutdown();
        }
    }

2 运行

新任务添加成功 : Task 0
    新任务添加成功 : Task 1
    新任务添加成功 : Task 2
    新任务添加成功 : Task 3
    新任务添加成功 : Task 4
    新任务添加成功 : Task 5
    正在做工中，执行者 : Task 0
    正在做工中，执行者 : Task 3
    正在做工中，执行者 : Task 1
    正在做工中，执行者 : Task 2
    正在做工中，执行者 : Task 4
    正在做工中，执行者 : Task 5
    
    Process finished with exit code 0