使用线程池和单线程

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用线程池和单线程相关的知识,希望对你有一定的参考价值。

 
/**
* 使用线程池和单线程
**/
public class TestTask {

    public static void main(String[] args) throws InterruptedException {
        long currentTimeMillis = System.currentTimeMillis();
        System.out.println("currentTimeMillis:" + currentTimeMillis);
        useThreadPool();
        System.out.println("cost:" + (System.currentTimeMillis() - currentTimeMillis));
        System.out.println("===================================================");
        currentTimeMillis = System.currentTimeMillis();
        useSinglePool();
        System.out.println("cost:" + (System.currentTimeMillis() - currentTimeMillis));

    }

    /**
     * 
     */
    private static void useSinglePool() {
        for (int i = 0; i < 10; i++) {
            doTask(RandomStringUtils.randomAlphanumeric(10), RandomStringUtils.randomAlphanumeric(5));
        }
    }

    /**
     * 
     */
    private static void useThreadPool() {
        ExecutorService es = Executors.newFixedThreadPool(10);
        List<Future<Boolean>> list = new ArrayList<Future<Boolean>>();
        for (int i = 0; i < 10; i++) {
            Future<Boolean> future = es.submit(new Callable<Boolean>() {

                @Override
                public Boolean call() {
                    return doTask(RandomStringUtils.randomAlphanumeric(10), RandomStringUtils.randomAlphanumeric(5));
                }
            });
            list.add(future);
        }
     //关闭线程池,等旧任务执行完,并停止接收新任务 es.shutdown();
try {
       //获取处理结果
for (Future<Boolean> future : list) { System.out.println(future.get()); } } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } public static boolean doTask(String arg1, String arg2) { System.out.println(Thread.currentThread() + ":" + arg1 + "_" + arg2); try {    //模拟业务处理时长 Thread.sleep(1000); return true; } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); return false; } } }

 

  

currentTimeMillis:1481104024029
Thread[pool-1-thread-2,5,main]:yaJSUdkD4f_v3rqW
Thread[pool-1-thread-3,5,main]:PpQbrtr7wP_KE78z
Thread[pool-1-thread-10,5,main]:LSODdw5Zqk_4LxLY
Thread[pool-1-thread-7,5,main]:KDseIk6FJ9_84qra
Thread[pool-1-thread-6,5,main]:ucm8VSevwB_WVOhS
Thread[pool-1-thread-4,5,main]:c132FVrokB_gtQDt
Thread[pool-1-thread-9,5,main]:KKcWv3rmVc_GR9LZ
Thread[pool-1-thread-5,5,main]:clXJOjW6F4_TlEzf
Thread[pool-1-thread-8,5,main]:aQBLjR4BTG_KwqBG
Thread[pool-1-thread-1,5,main]:jtyxUhMTSa_ykpVu
true
true
true
true
true
true
true
true
true
true
cost:1163
===================================================
Thread[main,5,main]:ncJJsfIfDH_pu7mj
Thread[main,5,main]:cFTiqRR8SZ_kXgYz
Thread[main,5,main]:k27V4Xzs43_9x7iC
Thread[main,5,main]:Butab2DJHb_4ePjg
Thread[main,5,main]:qhGBE1iyBE_SHOGj
Thread[main,5,main]:DEhiau4dqG_fxNa0
Thread[main,5,main]:byTFoqVkBC_Lb7vm
Thread[main,5,main]:Q544NhN0Lr_rpbwS
Thread[main,5,main]:5nNdV1G1nQ_VkvAK
Thread[main,5,main]:N3j4o8INfl_eLruR
cost:10001

 

以上是关于使用线程池和单线程的主要内容,如果未能解决你的问题,请参考以下文章

多线程和单线程代码维护

JAVA多线程 线程池和锁的深度化

Delphi - OTL - 线程池和工作线程之间的通信

线程池和CountDownLatch配合使用,大数据量批量多次处理

Java中的连接池和线程池设置

JDK线程池和Spring线程池的使用