java executor框架的应用

/* @param corePoolSize */

/* @param maximumPoolSize */

/* @param keepAliveTime 线程空闲时存活的有效时长 */

/* @param unit 时长单位 */

/* @param unit 时长单位 */

/* @param workQueue 等待执行的队列 */

/* maximumPoolSize是在workQueue队列满了之后才额外创建的线程数量 */

ThreadPoolExecutor tpe = new ThreadPoolExecutor(5, 10, 100, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));

/* 有返回值 */

Callable<String> callable = new Callable<String>() {

    public String call() throws Exception {

        try {

            Thread.sleep(5000);

            String a = "return String";

            return a;

        } catch (Exception e) {

            e.printStackTrace();

            return "exception";

        }

    }

};

Future<String> future = tpe.submit(callable);

/* 获取返回值，这是一个同步阻塞式获取的方法 */

future.get();

/* 有返回值 */

FutureTask<String> futureTask = new FutureTask<String>(callable);

futureTask.run();

/* 无返回值 */

Runnable runnable = new Runnable() {

    public void run() {

        try {

            Thread.sleep(5000);

            String a = "return String";

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

};

tpe.execute(runnable);