Java线程池的基础应用

jopen 9年前


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

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

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

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

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

并发库的基本应用:

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

第一种方式:

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

<pre class="java" name="code" snippet_file_name="blog_20141212_1_4629992" code_snippet_id="549759">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"); } }</pre>
会发现,每次都只有5个任务在执行,执行到10次,后再换下5个任务

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


第二种:

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

<pre class="java" name="code" snippet_file_name="blog_20141212_2_5247511" code_snippet_id="549759">ExecutorService threadPool = Executors.newCachedThreadPool();</pre>

第三种:

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

<pre class="java" name="code" snippet_file_name="blog_20141212_3_7557647" code_snippet_id="549759">ExecutorService threadPool = Executors.newSingleThreadExecutor();</pre>
用线程池启动定时器

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

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


<pre class="java" name="code" snippet_file_name="blog_20141212_4_980600" code_snippet_id="549759">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);</pre>

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

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