import java.util.concurrent.*; public class ExecutorsTest { public static void main(String[] args) { //ExecutorService threadPool = Executors.newFixedThreadPool(3);//固定大小线程池 //ExecutorService threadPool = Executors.newCachedThreadPool();//根据需要创建线程 ExecutorService threadPool = Executors.newSingleThreadExecutor();//创建单个线程,可以解决:线程死掉后可以重新启动线程的问题。实际上是新建一个线程,跟重新启动线程效果一样 for(int i=0;i<10;i++) { final int task = i+1; threadPool.execute(new Runnable(){ public void run() { for(int j=0;j<10;j++) System.out.println(Thread.currentThread().getName()+" loop of "+(j+1)+" task of "+task); } }); } threadPool.shutdown();//关闭线程池 System.out.println("all of 10 tasks have committed"); } }
import java.util.concurrent.*; public class ExecutorsTest { public static void main(String[] args) { ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(3); /*threadPool.schedule(new Runnable(){ public void run() { System.out.println(Thread.currentThread().getName()+" bombing"); } }, 2, TimeUnit.SECONDS); thradPool.shutdown(); */ threadPool.scheduleAtFixedRate(new Runnable(){ public void run() { System.out.println("bombing"); } }, 2, 1, TimeUnit.SECONDS); } }
import java.util.concurrent.*; public class ExecutorsTest { public static void main(String[] args) { ExecutorService threadPool = Executors.newFixedThreadPool(3); Future<Integer> future = threadPool.submit(new Callable<Integer>(){ public Integer call()throws Exception { System.out.println(Thread.currentThread().getName()); Thread.sleep(2000); return 3; } }); try{ System.out.println("main thread is coming"); Integer res = future.get();//get()方法会造成线程阻塞 System.out.println(res); }catch(Exception e){} threadPool.shutdown(); } }
import java.util.concurrent.*; import java.util.*; public class ExecutorsTest { public static void main(String[] args) { ExecutorService threadPool = Executors.newFixedThreadPool(3); Collection<Callable<Integer>> tasks = new ArrayList<Callable<Integer>>(); Callable<Integer> task1 = new Callable<Integer>(){ public Integer call()throws Exception { System.out.println(Thread.currentThread().getName()+" task 1"); Thread.sleep(2000); return 111111; } }; Callable<Integer> task2 = new Callable<Integer>(){ public Integer call()throws Exception { System.out.println(Thread.currentThread().getName()+" task 2"); Thread.sleep(2000); return 222222; } }; Callable<Integer> task3 = new Callable<Integer>(){ public Integer call()throws Exception { System.out.println(Thread.currentThread().getName()+" task 3"); Thread.sleep(2000); return 333333; } }; tasks.add(task1); tasks.add(task2); tasks.add(task3); System.out.println(tasks); try{ List<Future<Integer>> retval = threadPool.invokeAll(tasks);//同时执行多个任务 for(int i=0;i<retval.size();i++) { Integer res = retval.get(i).get();//get()方法会造成线程阻塞 System.out.println(res); } }catch(Exception e){} threadPool.shutdown(); } }
相关推荐
1. java.util.concurrent - Java 并发工具包 2. 阻塞队列 BlockingQueue 3. 数组阻塞队列 ArrayBlockingQueue 4. 延迟队列 DelayQueue 5. 链阻塞队列 LinkedBlockingQueue 6. 具有优先级的阻塞队列 ...
Tomcat内存溢出的解决方法(java.util.concurrent.ExecutionException:java.lang.OutOfMemoryError),内附解决方案!
java.util.concurrent系列文章(1) java.util.concurrent系列文章(1) java.util.concurrent系列文章(1) java.util.concurrent系列文章(1)
java并发工具包 java.util.concurrent中文版-带书签版
java.util.concurrent总体概览图。 收取资源分3分。需要的同学可以下载一下。 java.util.concurrent主要包括5个部分executor,colletions,locks,atomic,tools。 该图详细的列举了并发包下面的结构,包含所有接口和...
java并发工具包 java.util.concurrent中文版pdf
java.util.concurrent - Java 并发工具包 2. 阻塞队列 BlockingQueue 3. 数组阻塞队列 ArrayBlockingQueue 4. 延迟队列 DelayQueue 5. 链阻塞队列 LinkedBlockingQueue 6. 具有优先级的阻塞队列 ...
JDK1.5中的线程池(java.util.concurrent.ThreadPoolExecutor)使用
Java并发编程工具包java.util.concurrent的UML类结构图 PDF
java.util.concurrent系列文章(2) java.util.concurrent系列文章(2) java.util.concurrent系列文章(2) java.util.concurrent系列文章(2)
本文通过对数据压缩算法的简要介绍,然后以详细的示例演示了利用java.util.zip包实现数据的压缩与解压,并扩展到在网络传输方面如何应用java.util.zip包现数据压缩与解压
java.util.ConcurrentModificationException 异常问题详解1
如何启动:以win7系统为例,最好jdk8 1.打开cmd,cd到jdk的path,本机是:cd C:\Java\jdk6\bin ...java -cp D:\javaConcurrentAnimated.jar vgrazi.concurrent.samples.launcher.ConcurrentExampleLauncher
详细介绍了java.util.logging.Logger的用法和结构,对如果扩展Logger起到抛砖引玉的作用!尊重劳动成果,亲下载了要给个评价!
主要介绍了java.util.concurrent.ExecutionException 问题解决方法的相关资料,需要的朋友可以参考下
Exception in thread “main“ java.util.InputMismatchException
花了一段时间辛苦整理的ppt,与大家分享,请提出您的宝贵意见。
Doug Lea关于jdk里面并发同步器的实现。
AQS作者Doug lea关于AQS设计、性能的paper,需要了解AQS的设计思想,思路可以参考这篇paper