3. Semaphore
Semaphore是限制多线程共享资源的一个东东，多线程并发访问一个资源的时候，可以限制线程最大使用个数，其他多出来的线程，没办法，耐心等着吧。这个例子在生活中比比皆是，在火车站售票处一共开设了5个窗口，也就表示在同一时间内，火车站的工作人员最多只能为5个人服务，那么高峰时其他人呢，理想的情况下是排队等着，不理想的情况下是，等待的队列没有秩序，有的只是拳头和权势，没有办法，人家的爸爸是李刚，撞人都没事何况是排队买票了，人家说的就是王法。当然了，这个咱们看具体程序。
Java代码
package threadConcurrent.test;
import java.util.Random;
import java.util.concurrent.Semaphore;
/**
* 使用Semaphore，限制可以执行的线程数，空闲资源放到队列中等待
*
* @author liuyan
*/
public class SemaphoreDemo {
public static void main(String[] args) {
Runnable limitedCall = new Runnable() {
// 随机生成数
final Random rand = new Random();
// 限制只有3个资源是活动的,第二个参数为true则是按照标准“队列”结构先进先出
final Semaphore available = new Semaphore(5, true);
int count = 0;
public void run() {
int time = rand.nextInt(10);
int num = count++;
try {
// 请求资源
available.acquire();
int needTime = time * 2000;
System.out.println("乘客" + num + "买票需要[ " + needTime
+ " 秒]... #");
Thread.sleep(needTime);
System.out.println("乘客" + num + "买完了# !");
// 运行完了就释放
available.release();
} catch (InterruptedException intEx) {
intEx.printStackTrace();
}
}
};
for (int i = 0; i < 25; i++)
new Thread(limitedCall).start();
}
}
注释已经写得比较明确了，构建Semaphore的时候，第一个参数代表线程的执行的最大数目，第二个参数是按照队列的形式将未执行的线程放到队列中，当有线程执行完了后，按照先进先出的原则，进行线程的唤醒，执行。即便是main启动了25个线程，那么其余的线程要向执行也要等前面的线程执行完毕后才能有资格执行。要想让线程按规矩执行，首先应该先向资源池申请资源，available.acquire();就是请求资源池给个资源，如果资源池当前有空闲资源，那么线程就可以正常运行了，如果没有，没办法，排队吧啊。线程运行完毕了，要记得归还资源available.release();如果构造Semaphore的时候没指定第二个参数，或者第二个参数为false，估计您有幸能见到我之前说的李刚的儿子的现象！在此不再赘述。
4. ScheduledFuture
提到Quartz，大家都知道他是一个负责任务调度的开源工具，使用它可以轻易地在某一时段，某一频率执行相关业务功能。如果仅仅是简单的根据某些时间频率执行某些任务，其实到不必屠龙刀杀小鸡，使用ScheduledFuture可以轻松解决此类频率的问题，启动另一个线程来，在某一个时间频率执行代码。这个还是举个例子吧，战争年代巡视城防，赵云带一个小兵去巡视城防，赵云是将军，每5秒钟巡视一次士兵，看看士兵有没有偷懒，士兵比较累，每1秒巡视一次城防，不能睡觉。如下程序
Java代码
package threadConcurrent.test;
import static java.util.concurrent.TimeUnit.SECONDS;
import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
/**
* 时间频率调度
* @author liuyan
*/
public class ScheduledFutureDemo {
@SuppressWarnings("unchecked")
public static void main(String[] args) {
// 线程池开辟2个线程
final ScheduledExecutorService scheduler = Executors
.newScheduledThreadPool(2);
// 将军
final Runnable general = new Runnable() {
int count = 0;
public void run() {
System.out.println(Thread.currentThread().getName() + ":"
+ new Date() + "赵云巡视来了" + (++count));
}
};
// 士兵
final Runnable soldier = new Runnable() {
int count = 0;
public void run() {