本文共 860 字,大约阅读时间需要 2 分钟。
package com.ran;import java.util.concurrent.*;import java.util.concurrent.locks.ReentrantLock;public class ran { public static void main(String[] args) { ExecutorService service = Executors.newFixedThreadPool(10); ThreadPoolExecutor service1= (ThreadPoolExecutor) service; //线程池的属性设置 service1.setCorePoolSize(15); service1.setKeepAliveTime(); service.execute(new duoxiancheng()); //适合适用于Runnable service.shutdown();// service.submit(); //适合适用于Callable }}class duoxiancheng implements Runnable{ @Override public void run() { for (int i = 0; i <=100 ; i++) { if(i % 2 == 0){ System.out.println(Thread.currentThread().getName()+" "+i); } } }}
转载地址:http://mkox.baihongyu.com/