线程阻塞工具类 ：LockSupport
- LockSupport 是一个非常实用的线程阻塞工具， 可以在线程内任意位置，让线程阻塞。 这个类补充了 使用resume 导致线程无法继续执行的情况，和wait方法相比 ，不需要获得某个对象的锁 ，也不会抛出 中断异常。
public class LockSupportDemo {
public static Object U = new Object() ;
static ChangeObjectThread t1 = new ChangeObjectThread("t1");
static ChangeObjectThread t2 = new ChangeObjectThread("t2");
public static class ChangeObjectThread extends Thread{
public ChangeObjectThread (String name){
super.setName(name);
}
@Override
public void run() {
synchronized(U){
System.out.println("in " + getName());
LockSupport.park();
}
}
}
public static void main(String[] args) throws Exception {
t1.start();
Thread.sleep(100);
t2.start();
LockSupport.unpark(t1);
LockSupport.unpark(t2);
t1.join();
t2.join();
}
}
- 在该代码中，我们使用的是方法park(),和unpark(); 该类为每个线程准备了一个许可， 如果许可可用，那么park()函数就会立即返回，消费掉这个许可，。 如果许可不可用，就会发生阻塞。这个优点是即使 unpark ()发生在park上 ，也能顺利的保证park操作正确执行。
- 除了有定时阻塞的功能之外， park()还支持 中断影响,但是与其他中断函数不一样，park()函数 不会抛出中断异常， 只是默默返回。 但是我们可以用 Thread.interupted() 等方法获得中断标记。代码演示如下......
public class LockSupportIntDemo {
public static Object U = new Object() ;
static ChangeObjectThread t1 = new ChangeObjectThread("t1");
static ChangeObjectThread t2 = new ChangeObjectThread("t2");
public static class ChangeObjectThread extends Thread{
public ChangeObjectThread (String name){
super.setName(name);
}
@Override
public void run() {
synchronized(U){
System.out.println("in " + getName());
LockSupport.park();
if(Thread.interrupted()){
System.out.println(getName() + "被中断了");
}
}
System.out.println(getName() + "执行结束了");
}
}
public static void main(String[] args) throws Exception {
t1.start();
Thread.sleep(100);
t2.start();
t1.interrupt();
LockSupport.unpark(t2);
}
}
临界
线程复用：线程池
- 线程池是为了方便我们对创建的线程进行复用。节约了创建和销毁对象的时间。
线程池的使用
jdk 对线程池的使用。
- jdk 提供了一套Executor 框架， 本质就是线程池的使用。
Executor框架
- 从图中可以看到ThreadPoolExecutor 表示一个线程池， Executors 类则扮演者线程池工厂的角色。 通过Executors 可以获得拥有特定功能的线程池。 我们在uml图上 ，可以看到Executor 接口 ，我们通过该接口 让Runnable 的对象可以被ThreadPoolExecutor 线程池调度。
- Executor 框架提供了各种类型线程池。工厂方法如下：
- newFixedThreadPool(int nThreads); 该方法返回的是一个固定线程数量的线程池，该线程池的线程数量始终不变。 当有新任务提交过来的时候 ，线程池中有空闲线程，则立即执行。若没有 ，则会把新的任务放到一个队列中。等待有空闲线程的时候就会执行队列中的任务。
- newSingleThreadExecutor(): 方法会返回一个只有一个线程的线程池。若多余一个任务被提交到该线程池。任务同样会保存在任务队列中，等待线程空闲，按照先入先出的顺序 执行队列中的任务。
- newCachedThreadPool() 方法： 方法会返回一个根据实际情况调整线程数量的线程池。线程池的里面的线程数量不确定。在任务提交过来的时候，若有空闲线程 则直接复用空闲线程，若所有线程都在使用，那么会创建新的线程处理任务。所有线程结束后，将返回线程池进行复用。
- newSingThreadScheduleExecutor(): 该方法会返回一个ScheduledExecutorService对象，线程池大小为1， 这个线程池是在给定任务时间执行某任务的功能，或者是周期性执行任务
- newSheduledThreadPool(): 方法会返回ScheduledExecutorService对象，该线程池可以指定线程数量。
- 对计划任务线程池的使用：newSheduledThreadPool():
- 主要方法如下 对该线程里面的设置。
/**下面两种方法 会在给定时间进行一次任务调度。**/
public ScheduledFuture<?> schedule(Runnable command,
long delay, TimeUnit unit);
public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit);
/*** 该方法是对任务周期性的调度 fixRate 是任务调度频率是一致的**/
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit);
/***同样 周期性的调度 FixedDelay 是在任务完成一周周期后 再经过某个时间长度 才会执行任务**/
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,long initialDelay,
long delay, TimeUnit unit);
//代码演示如下：
public class ScheduledExecutorServiceDemo {
public static void main(String[] args) {
ScheduledExecutorService service = Executors.newScheduledThreadPool(10);
service.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(1000);
System.out.println(System.currentTimeMillis() / 1000);
} catch (Exception e) {
e.printStackTrace();
}
}
}, 0, 2, TimeUnit.SECONDS);
}
}
每隔两秒
- 还有一种情况如果任务执行时间超过我们所规定的时间 ，会怎么样，是聚集还是？ 答案就是 会持续的当当前任务执行完成后立即执行下面的任务，。还有一个如果任务出现异常，那么该任务会被中断 后续的任务也会被中断，那么需要我们最好异常处理。
网友评论