Java并发篇--异步模式之工作线程

异步模式之工作线程

定义

让有限的工作线程（Worker Thread）来轮流异步处理无限多的任务。也可以将其归类为分工模式，它的典型实现就是线程池，也体现了经典设计模式中的享元模式。

注意,不同任务类型应该使用不同的线程池,这样能够避免饥饿,并能提升效率。

饥饿

固定大小线程池会有饥饿现象

两个工人是同一个线程池中的两个线程

他们要做的事情是：为客人点餐和到后厨做菜,这是两个阶段的工作

比如工人A 处理了点餐任务,接下来它要等着工人B 把菜做好,然后上菜,他俩也配合的蛮好

但现在同时来了两个客人,这个时候工人A 和工人B 都去处理点餐了,这时没人做饭了,饥饿

问题提出

@Slf4j(topic = "c.StarvationDemo")
public class StarvationDemo {static final List<String> MENU = Arrays.asList("地三鲜","宫保鸡丁","辣子鸡丁","烤鸡翅");static Random RANDOM = new Random();static String coke(){return MENU.get(RANDOM.nextInt(MENU.size()));}public static void main(String[] args) {ExecutorService pool = Executors.newFixedThreadPool(2);pool.execute(()->{log.debug("处理点餐...");Future<String> f = pool.submit(() -> {log.debug("做菜");return coke();});try {log.debug("上菜: {}",f.get());} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}});pool.execute(()->{log.debug("处理点餐...");Future<String> f = pool.submit(() -> {log.debug("做菜");return coke();});try {log.debug("上菜: {}",f.get());} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}});}
}

运行该代码后会发现两个线程都停在了处理点餐,都在等待其它线程做菜。

问题解决

将不同的任务放入不同的线程池。

@Slf4j(topic = "c.StarvationDemo")
public class StarvationDemo {static final List<String> MENU = Arrays.asList("地三鲜","宫保鸡丁","辣子鸡丁","烤鸡翅");static Random RANDOM = new Random();static String coke(){return MENU.get(RANDOM.nextInt(MENU.size()));}public static void main(String[] args) {ExecutorService waiterPool = Executors.newFixedThreadPool(2);ExecutorService cookPool = Executors.newFixedThreadPool(2);waiterPool.execute(()->{log.debug("处理点餐...");Future<String> f = cookPool.submit(() -> {log.debug("做菜");return coke();});try {log.debug("上菜: {}",f.get());} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}});waiterPool.execute(()->{log.debug("处理点餐...");Future<String> f = cookPool.submit(() -> {log.debug("做菜");return coke();});try {log.debug("上菜: {}",f.get());} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}});}
}