概述

Callable介绍见：http://blog.csdn.net/zengmingen/article/details/53288119

多线程介绍见：http://blog.csdn.net/zengmingen/article/details/53284999

代码

TaskCallable.java

package multithreading.pool;import java.util.concurrent.Callable;public class TaskCallable implements Callable<String>{/**线程编号*/private int tNo;public TaskCallable(int tNo){this.tNo=tNo;}@Overridepublic String call() throws Exception {String tName=Thread.currentThread().getName();long currentTimeMillis = System.currentTimeMillis();System.out.println(tNo+"-"+tName+" start time is："+currentTimeMillis/1000);try {Thread.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(tNo+"-"+tName+ " is working...");return "the thread is "+tNo;}}

TestPool.java

package multithreading.pool;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;public class TestPool {public static void main(String[] args) throws Exception, ExecutionException {List<Future<String>> futures = new ArrayList<Future<String>>();ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(2);for (int i = 0; i < 5; i++) {Future<String> future = newFixedThreadPool.submit(new TaskCallable(i));futures.add(future);}// 打印结果for (Future<String> f : futures) {boolean done = f.isDone();// 从结果的打印顺序可以看到，即使未完成，也会阻塞等待System.out.println(done ? "已完成" : "未完成");//从Future中get结果，这个方法是会被阻塞的，一直要等到线程任务返回结果System.out.println("已完成线程返回future结果： " + f.get());}newFixedThreadPool.shutdown();}}

运行结果

0-pool-1-thread-1 start time is：1479808023
未完成
1-pool-1-thread-2 start time is：1479808023
0-pool-1-thread-1 is working...
1-pool-1-thread-2 is working...
已完成线程返回future结果： the thread is 0
已完成
已完成线程返回future结果： the thread is 1
未完成
2-pool-1-thread-1 start time is：1479808024
3-pool-1-thread-2 start time is：1479808024
3-pool-1-thread-2 is working...
2-pool-1-thread-1 is working...
4-pool-1-thread-2 start time is：1479808026
已完成线程返回future结果： the thread is 2
已完成
已完成线程返回future结果： the thread is 3
未完成
4-pool-1-thread-2 is working...
已完成线程返回future结果： the thread is 4

-------------

更多的Java，Angular，Android，大数据，J2EE，Python，数据库，Linux，Java架构师，：

http://www.cnblogs.com/zengmiaogen/p/7083694.html

线程池与Callable更配哦相关推荐

创建线程（Lock()、线程池、Callable()）及线程通信
package com.xt.java;import java.util.concurrent.locks.ReentrantLock;/*** 解决线程安全问题的方式三:Lock锁 -->JD ...
Java线程池 / Executor / Callable / Future
为什么需要线程池? 每次都要new一个thread,开销大,性能差:不能统一管理:功能少(没有定时执行.中断等). 使用线程池的好处是,可重用,可管理. Executor 4种线程池 // 可缓存线程 ...
java callable 线程池_JAVA 线程池之Callable返回结果
本文介绍如何向线程池提交任务,并获得任务的执行结果.然后模拟线程池中的线程在执行任务的过程中抛出异常时,该如何处理. 一,执行具体任务的线程类要想获得线程的执行结果,需实现Callable接口 ...
创建线程的四种方式（Thread、Runnable、线程池、Callable）
目录一.直接继承Thread类,然后重写run方法二.实现Runnable接口三.线程池创建四.实现Callable接口创建线程有四种方式:1.继承Thread类 2.实现Runnabl ...
Android中Callable、Future、FutureTask的概念以及几种线程池的使用
学习线程池必备知识: 在开始介绍线程池之前,先来介绍下Callable和Future的概念,众所周知,Android中实现多线程的方式有两种,实现Runnable接口或者继承一个Thread,但是这两 ...
java同步锁售票_Java基础学习笔记：多线程，线程池，同步锁（Lock，synchronized ）(Thread类,ExecutorService ，Future类)（卖火车票案例）...
学习多线程之前,我们先要了解几个关于多线程有关的概念. 进程:进程指正在运行的程序.确切的来说,当一个程序进入内存运行,即变成一个进程,进程是处于运行过程中的程序,并且具有一定独立功能. 线程:线程是 ...
Java 并发编程——Executor框架和线程池原理
Java 并发编程系列文章 Java 并发基础--线程安全性 Java 并发编程--Callable+Future+FutureTask java 并发编程--Thread 源码重新学习 java并发 ...
Java 线程池详解及实例代码
转载自 Java 线程池详解及实例代码这篇文章主要介绍了Java 线程池的相关资料,并符实例代码,帮助大家学习参考,需要的朋友可以参考下线程池的技术背景在面向对象编程中,创建和销毁对象是很费时 ...
Java线程池，从使用到原理
转载自 Java线程池,从使用到原理线程池的技术背景在面向对象编程中,创建和销毁对象是很费时间的,因为创建一个对象要获取内存资源或者其它更多资源.在Java中更是如此,虚拟机将试图跟踪每一个对象 ...

线程池与Callable更配哦

概述

代码

线程池与Callable更配哦相关推荐

最新文章

热门文章