假如我們模擬一個場景，就是用戶注冊的時候，在注冊成功以后發放積分。這個場景在一般來說，我們會這么去實現

但是實際上，我們需要考慮兩個問題

1. 性能，在注冊這個環節里面，假如添加用戶需要花費1秒鐘，增加積分需要花費1秒鐘，那么整個注冊結果的返回就可能需要大于2秒，雖然影響不是很大，但是在量比較大的時候，我們也需要做一些優化?

2. 耦合，添加用戶和增加積分，可以認為是兩個領域，也就是說，增加積分并不是注冊必須要具備的功能，但是一旦增加積分這個邏輯出現異常，就會導致注冊失敗。這種耦合在程序設計的時候是一定要規避的

因此我們可以通過異步的方式來實現

改造之前的代碼邏輯

public class UserService { public boolean register(){ User user=new User(); user.setName("Mic"); addUser(user); sendPoints(user); return true; } public static void main(String[] args) { new UserService().register();} private void addUser(User user){ System.out.println("添加用戶："+user); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } private void sendPoints(User user){ System.out.println("發送積分給指定用戶:"+user); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }

改造之后的邏輯

public class UserService { private final ExecutorService single = Executors.newSingleThreadExecutor(); private volatile boolean isRunning = true; ArrayBlockingQueue arrayBlockingQueue=new ArrayBlockingQueue(10); { init(); } public void init(){ single.execute(()->{ while(isRunning){ try { User user=(User)arrayBlockingQueue.take();//阻塞的方式獲取隊列中的數據sendPoints(user); } catch (InterruptedException e) { e.printStackTrace(); } } }); } public boolean register(){ User user=new User(); user.setName("Mic"); addUser(user); arrayBlockingQueue.add(user);//添加到異步隊列 return true; } public static void main(String[] args) { new UserService().register(); } private void addUser(User user){ System.out.println("添加用戶："+user); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } private void sendPoints(User user){ System.out.println("發送積分給指定用戶:"+user); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }

優化以后，整個流程就變成了這樣

?

總結

以上是生活随笔為你收集整理的阻塞队列的使用案例-注册成功后增加积分的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。