1、Semaphore的初步使用
Semaphore是什么，能做什么？
Semaphore 是 synchronized 的加强版，作用是控制线程的并发数量。就这一点而言，单纯的synchronized 关键字是实现不了的。
直接看例子吧，这个例子包含3个类，一个是线程类，一个是 Semaphore 关键代码类，一个类是主main方法类：
public class MyThread extends Thread {
private SemaphoreService service;
public MyThread(String name, SemaphoreService service) {
super();
this.setName(name);
this.service = service;
}
@Override
public void run() {
this.service.doSomething();
}
}
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.Semaphore;
public class SemaphoreService {
private static SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
private **Semaphore semaphore = new Semaphore(1)**;// 同步关键类，构造方法传入的数字是多少，则同一个时刻，只运行多少个进程同时运行制定代码
public void doSomething() {
try {
/**
* 在 semaphore.acquire() 和 semaphore.release()之间的代码，同一时刻只允许制定个数的线程进入，
* 因为semaphore的构造方法是1，则同一时刻只允许一个线程进入，其他线程只能等待。
* */
semaphore.acquire();
System.out.println(Thread.currentThread().getName() + ":doSomething start-" + getFormatTimeStr());
Thread.sleep(2000);
System.out.println(Thread.currentThread().getName() + ":doSomething end-" + getFormatTimeStr());
semaphore.release();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static String getFormatTimeStr() {
return sf.format(new Date());
}
}
public class SemaphoreTest {
public static void main(String args[]) {
SemaphoreService service = new SemaphoreService();
for (int i = 0; i < 10; i++) {
MyThread t = new MyThread("thread" + (i + 1), service);
t.start();// 这里使用 t.run() 也可以运行，但是不是并发执行了
}
}
}
