Executors 工具类 创建 的 线程池
发布时间:2020-05-25 15:32:35 所属栏目:Java 来源:互联网
导读:Executors 工具类 创建 的 线程池
|
下面是脚本之家 jb51.cc 通过网络收集整理的代码片段。 脚本之家小编现在分享给大家,也给大家做个参考。 import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ThreadPoolTest {
static int num = 100;
public static void main(String[] args) throws InterruptedException {
//固定线程数量的线程池,有任务就派空闲线程去执行,多余的任务等待
//ExecutorService pool= Executors.newFixedThreadPool(3);
//根据任务需要,自动创建线程,且 前面已创建的线程,空闲时,可被复用
//ExecutorService pool= Executors.newCachedThreadPool();
//单个线程,若执行期出现失败而终止此单个线程,则会建一个新线程来代替,运行任务
ExecutorService pool= Executors.newSingleThreadExecutor();
//给线程池加 10条任务
for (int j= 0; j < 10; j++) {
final int task = j;
pool.execute(new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
for (int i=0; i < 10; i++) {
System.out.println(Thread.currentThread().getName() + "--" +i
+ "--" + task + " of taks" + " 计数:" + (--num));
}
}
});
// Thread.sleep(20);
}
//可安排在给定的延迟后运行或定期执行的命令。
ScheduledExecutorService service = Executors.newScheduledThreadPool(3);
for (int i = 0; i < 5; i++) {
final int x = i;
service.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
System.out.println("Boon " + x + " " + Thread.currentThread().getName());
}
},2,TimeUnit.SECONDS);//延迟0秒,周期2秒
}
//poor.shutdownNow();//试图马上停了所有正在执行的任务,返回任务列表
pool.shutdown();//把分配给线程池的任务都执行完,就不再等待接受新任务了,
// service.shutdown();
}
}
以上是脚本之家(jb51.cc)为你收集整理的全部代码内容,希望文章能够帮你解决所遇到的程序开发问题。 如果觉得脚本之家网站内容还不错,欢迎将脚本之家网站推荐给程序员好友。 (编辑:安卓应用网) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
