码迷,mamicode.com
首页 > 编程语言 > 详细

Java线程池的基础应用

时间:2014-12-12 01:23:49      阅读:216      评论:0      收藏:0      [点我收藏+]

标签:style   blog   io   ar   sp   for   java   strong   on   


了解:原子性操作类的基础用法

在java5以后,增加很多线程的内容,成为线程得并发库。

在java.util.concurrent包及子包的API帮助文档,上面有对并发库涉及内容

在java.util.concurrent.atomic包,有对基本数据,对数组中的基本数据,类中的基本数据等的操作

AtomicIneger类,可以解决多线程访问整数的问题
AtomicBoolean.....
AtomicArray...操作数组的基本数据
AtomicIntegerFieldUodater<T>,操作类中的基本数据

并发库的基本应用:

关于线程池的理解加深
以前只是知道有线程池这个东西,并不是很了解。

第一种方式:

Executors工具类,创建一个线程池,固定的线程池

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadAtomic {

	public static void main(String[] args) {
		
		//5个线程的线程池
		ExecutorService threadPool = Executors.newFixedThreadPool(5);
			for(int j = 1;j<=10;j++){
				final int task = j;
				threadPool.execute(new Runnable(){
	
				public void run() {
					for(int i = 1;i<=10;i++){
						try {
							Thread.sleep(30);
						} catch (Exception e) {
							e.printStackTrace();
						}		
					System.out.println(Thread.currentThread().getName()+
							" is running "+i+" for task is "+ task);
					}
				}
			});//向池子中添加任务
		}
			System.out.println("10 task is over");
	}
}

会发现,每次都只有5个任务在执行,执行到10次,后再换下5个任务

所以,池子中有n个线程,向池子中添加m个任务,能被执行的任务的最大数是n个,剩下的还未被执行的任务还在排队等待。而且,不结束,因为池子中还有线程,虽然没事干,但还是在等待threadPool.shutdownNow()/shutdown(),结束,就算还有任务也会被结束,该方法就是杀死池子中的所有线程。


第二种:

缓存的线程池,简单说就是线程池中的线程个数不确定,当有3个任务的时候,池子中的线程就是3个,每个线程拿一个任务做,当任务减少
时,池子中的多余线程会被回收,总之,池子中的线程是动态的

ExecutorService threadPool = Executors.newCachedThreadPool();


第三种:

只有一个线程的线程池,实际上不能叫做线程池,但是该线程池有一个好处,就是池中的线程死掉了,会自动创建一个新的线程,总之,
会保证池子中有一个线程存在,这也就可以解决,如何在线程死掉以后使其重新启动

ExecutorService threadPool = Executors.newSingleThreadExecutor();

用线程池启动定时器

调用ScheduledExectorService的schedule方法,返回的scheduleFuture对象可以取消任务

支持间隔重复任务的定时方式,不直接支持绝对定时方式,需要转换成相对时间方式


Executors.newScheduledThreadPool(3).schedule(new Runnable() {
		
				public void run() {
					System.out.println("ok!");
				}
			}, 3, TimeUnit.SECONDS);
//3秒后打印ok


Executors.newScheduledThreadPool(3).scheduleAtFixedRate(new Runnable() {
		
				public void run() {
					System.out.println("ok!");
				}
			}, 3,2, TimeUnit.SECONDS);


//3秒后ok,以后每隔2秒ok

注意它没有提供,比如今天晚上9点...的方法,所以可以用今天晚上9点的毫秒值-当前时间的毫秒值,来设置


Java线程池的基础应用

标签:style   blog   io   ar   sp   for   java   strong   on   

原文地址:http://blog.csdn.net/wjw0130/article/details/41882275

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!