首页 > 代码库 > Java线程池的基础应用

Java线程池的基础应用

2024-08-07 13:08:34   221人阅读


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

在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线程池的基础应用


联系
我们