编程语言
首页 > 编程语言> > Java线程池的应用

Java线程池的应用

作者:互联网

一 使用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

 

标签:...,Task,Java,name,执行者,计算,线程,应用,public
来源: https://blog.csdn.net/chengqiuming/article/details/95893341