ScheduledExecutorService exec = Executors.newScheduledThreadPool(10); exec.schedule(new Runnable() { @Override public void run() { System.out.println("delay 5 second!"); } }, 5, TimeUnit.SECONDS); exec.scheduleAtFixedRate(new Runnable() { @Override public void run() { System.out.println("init 1 delay 5"); } }, 1, 5, TimeUnit.SECONDS); exec.scheduleWithFixedDelay(new Runnable() { @Override public void run() { System.out.println("init 2 delay 7"); } }, 2, 5, TimeUnit.SECONDS);
1.Executor框架
public class ExecutorTest { public static void main(String[] args) { Executor exe = Executors.newFixedThreadPool(10); for (int i = 1; i <= 20; i++) { final int k = i; Runnable run = new Runnable() { @Override public void run() { System.out.println(k); } }; exe.execute(run); } } }
线程池:
newFixedThreadPool: 固定长度的线程池
newCachedThreadPool: 可缓存的线程池(回收空闲线程,增加新线程)
newSingleThreadExecutor: 保证只有一个线程工作
newScheduledThreadPool: 固定长度的线程池,并且可以延迟或定时的执行任务
2.ExecutorService
状态: 运行、关闭、已终止
private ExecutorService es = Executors.newFixedThreadPool(10); public void start() { int i = 0; while(!es.isShutdown()) { i ++; es.execute(new Runnable() { @Override public void run() { System.out.println("oo"); } }); if(i == 10) { stop(); } } } public void stop() { es.shutdown(); }
3.延迟任务和周期任务类
使用ScheduledThreadPool来替代Timer,Timer执行所有的定时任务只会创建一个线程
构建自己的定时任务最好使用DelayQueue
ScheduledExecutorService exec = Executors.newScheduledThreadPool(10); exec.schedule(new Runnable() { @Override public void run() { System.out.println("delay 5 second!"); } }, 5, TimeUnit.SECONDS); exec.scheduleAtFixedRate(new Runnable() { @Override public void run() { System.out.println("init 1 delay 5"); } }, 1, 5, TimeUnit.SECONDS); exec.scheduleWithFixedDelay(new Runnable() { @Override public void run() { System.out.println("init 2 delay 7"); } }, 2, 5, TimeUnit.SECONDS);
4.携带结果Callable和Future
FutureTask对Future进行了封装
future = executor.submit(callable);
future.get()
future.cancell(true);
future.isCancelled()
future.isDone()
5.CompletionService
将已完成的结果保存在BlockingQueue中,结果完成时被封装成Future
package com.sosop.nio.buffer; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class ExecutorTest { public static void main(String[] args) throws InterruptedException { ExecutorService exec = Executors.newFixedThreadPool(10); ExecutorCompletionService<Integer> completion = new ExecutorCompletionService<>( exec); for (int i = 0; i < 20; i++) { completion.submit(new Worker(i, i+1)); } try { for (int i = 0; i < 20; i++) { Future<Integer> f = completion.take(); int result = f.get(); System.out.println(result); } } catch (ExecutionException e) { e.printStackTrace(); } finally { exec.shutdown(); } } } class Worker implements Callable<Integer> { private int num1; private int num2; public Worker(int num1, int num2) { this.num1 = num1; this.num2 = num2; } @Override public Integer call() throws Exception { return num1 + num2; } }
相关推荐
线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池...
corePoolSize:核心池的大小,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务,当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中; ...
阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池...
一、线程池 1、为什么需要使用线程池 1.1 创建/销毁线程伴随着系统开销,过于频繁的创建/销毁线程,会很大程度上影响处理效率。 记创建线程消耗时间T1,执行任务消耗时间T2,销毁线程消耗时间T3,如果T1+T3>T2,那...
VC实现线程池
易语言简易线程池的实现。 ——V雪落有声V原创。转载请保留。前文:。为了能充分理解本篇文章的内容,需要了解的知识如下:。1.事件对象的使用:http://baike.baidu.com/view/751499.htm。2.信号量的使用:...
简单的线程池程序+中文文档 包结构: com.tangkai.threadpool --SimpleThread.java 工作线程 --TestThreadPool.java 程序入口 --ThreadPoolManager.java 线程池管理类
Windows下一个比较完美的线程池实现和示例 本线程池提供了如下功能: 1.能根据任务个数和当前线程的多少在最小/最大线程个数之间自动调整(Vista后的系统有 SetThreadpoolThreadMaximum 等函数有类似功能); 2.能方便...
C#管理线程池的类 /* How to use Thread Classs * * ============== * public ELMService() { InitializeComponent(); etm.ClalThreadPool("EmailThreads", (uint)ApplicationInfo.EmailParsingThreads); ...
线程池
因为本人是个小白,多线程经常用,但是线程池并没有用过,(一听到线程池,总感觉高大上)。但是近期写彩票软件的时候发现,多线程长期操作会导致内容不断的升高直至报错,遂想起了线程池,完善后发现不是一般的叼...
2.然后根据提示运行java命令执行示例程序,观看线程池的运行结果 目标:Java中多线程技术是一个难点,但是也是一个核心技术。因为Java本身就是一个多线程语言。本人目前在给46班讲授Swing的网络编程--使用Swing来...
1.线程池管理器(ThreadPoolManager):用于创建并管理线程池 2.工作线程(WorkThread): 线程池中线程 3.任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行。 4.任务队列:用于存放没有处理的...
以下示例显示如何使用线程池。首先创建 ManualResetEvent 对象,此对象使程序能够知道线程池何时运行完所有的工作项。接着,尝试向线程池添加一个线程。如果添加成功,则添加其余的线程(本例中为 4 个)。然后...
linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现
使用Windows自带的线程池功能,比你写的线程池性能好得多
什么是线程池?简单点说,线程池就是有一堆已经创建好了的线程,初始它们都处于空闲等待状态,当有新的任务需要处理的时候,就从这个池子里面取一个空闲等待的线程来处理该任务,当处理完成了就再次把该线程放回池中...
这是一个简单线程池的实现,虽然有很多bug,但是能够简单地实现线程池。
Java开发,Android开发,自己实现线程池,明白线程池的实现机制
本实例采用c3p0作为线程池工具包,讲解了jdbc基本用法,同时给出了Oracle以及mysql增(单插入、批量插入)、删、查、改等功能,可以直接复制使用。