java 并发工具类-Semaphore
2017-03-06 14:01
513 查看
Semaphore可以用于做流量控制,特别是公用资源有限的应用场景,比如数据库连接。假
如有一个需求,要读取几万个文件的数据,因为都是IO密集型任务,我们可以启动几十个线程并发地读取,但是如果读到内存后,还需要存储到数据库中,而数据库的连接数只有10个,这时我们必须控制只有10个线程同时获取数据库连接保存数据,否则会报错无法获取数据库连接。这个时候,就可以使用Semaphore来做流量控制
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class SemaphoreTest {
private static final int THREAD_COUNT = 30;
private static ExecutorService threadPool = Executors.newFixedThreadPool(THREAD_COUNT);
private static Semaphore s = new Semaphore(10);
public static void main(String[] args) {
for (int i = 0; i < THREAD_COUNT; i++) {
threadPool.execute(new Runnable() {
@Override
public void run() {
try {
s.acquire(); //获取一个许可证
System.out.println("save data");
s.release(); //归还许可证
} catch (InterruptedException e) {
}
}
});
}
threadPool.shutdown();
}
}
虽然有30个线程在执行,但是只允许10个并发执行。Semaphore的构造方法
Semaphore(int permits)接受一个整型的数字,表示可用的许可证数量。Semaphore(10)表示允许10个线程获取许可证,也就是最大并发数是10。Semaphore的用法也很简单,首先线程使用Semaphore的acquire()方法获取一个许可证,使用完之后调用release()方法归还许可证。还可以
用tryAcquire()方法尝试获取许可证。
如有一个需求,要读取几万个文件的数据,因为都是IO密集型任务,我们可以启动几十个线程并发地读取,但是如果读到内存后,还需要存储到数据库中,而数据库的连接数只有10个,这时我们必须控制只有10个线程同时获取数据库连接保存数据,否则会报错无法获取数据库连接。这个时候,就可以使用Semaphore来做流量控制
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class SemaphoreTest {
private static final int THREAD_COUNT = 30;
private static ExecutorService threadPool = Executors.newFixedThreadPool(THREAD_COUNT);
private static Semaphore s = new Semaphore(10);
public static void main(String[] args) {
for (int i = 0; i < THREAD_COUNT; i++) {
threadPool.execute(new Runnable() {
@Override
public void run() {
try {
s.acquire(); //获取一个许可证
System.out.println("save data");
s.release(); //归还许可证
} catch (InterruptedException e) {
}
}
});
}
threadPool.shutdown();
}
}
虽然有30个线程在执行,但是只允许10个并发执行。Semaphore的构造方法
Semaphore(int permits)接受一个整型的数字,表示可用的许可证数量。Semaphore(10)表示允许10个线程获取许可证,也就是最大并发数是10。Semaphore的用法也很简单,首先线程使用Semaphore的acquire()方法获取一个许可证,使用完之后调用release()方法归还许可证。还可以
用tryAcquire()方法尝试获取许可证。
相关文章推荐
- Java并发工具类Semaphore应用实例
- Java并发工具类之Semaphore
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- Java并发工具类(三):控制并发线程数的Semaphore
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- 第8章 Java中的并发工具类(CountDownLatch CyclicBarrier Semaphore Exchanger)
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- java并发之同步工具类二之信号灯semaphore
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- Java并发编程之2——同步工具类的使用(CountDownLatch,CyclicBarrier,BlockungQueue,Semaphore)
- 一直被忽略的java 多线程并发工具类 CountDownLatch、Semaphore
- Java并发:同步工具类详解(CountDownLatch、CyclicBarrier、Semaphore)
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- 【死磕Java并发】—– J.U.C之并发工具类:Semaphore
- Java中的并发工具类:CountDownLatch、CyclicBarrier和Semaphore
- Java并发工具类之并发数控制神器Semaphore
- 【死磕Java并发】-----J.U.C之并发工具类:Semaphore