Java涓殑BlockingQueue鏄竴涓嚎绋嬪畨鍏ㄧ殑闃熷垪瀹炵幇锛屽畠鏀寔鍦ㄧ敓浜ц€呭拰娑堣垂鑰呬箣闂磋繘琛屾暟鎹氦鎹€備互涓嬫槸BlockingQueue鐨勪娇鐢ㄦ柟娉曪細

1. 鍒涘缓BlockingQueue瀵硅薄锛氬彲浠ヤ娇鐢ˋrrayBlockingQueue銆丩inkedBlockingQueue鎴朠riorityBlockingQueue绛夊疄鐜扮被鏉ュ垱寤轰竴涓狟lockingQueue瀵硅薄銆備緥濡傦細

BlockingQueue<Integer> queue = new LinkedBlockingQueue<>();

2. 鐢熶骇鑰呭悜闃熷垪涓坊鍔犲厓绱狅細鍙互浣跨敤put()鏂规硶灏嗗厓绱犳坊鍔犲埌闃熷垪涓€傚鏋滈槦鍒楀凡婊★紝put()鏂规硶浼氶樆濉炵洿鍒伴槦鍒楁湁绌洪棽浣嶇疆銆備緥濡傦細

queue.put(1);

3. 娑堣垂鑰呬粠闃熷垪涓彇鍑哄厓绱狅細鍙互浣跨敤take()鏂规硶浠庨槦鍒椾腑鍙栧嚭鍏冪礌銆傚鏋滈槦鍒椾负绌猴紝take()鏂规硶浼氶樆濉炵洿鍒伴槦鍒楁湁鏂扮殑鍏冪礌銆備緥濡傦細

int item = queue.take();

4. 鍏朵粬甯哥敤鏂规硶锛欱lockingQueue杩樻彁渚涗簡涓€浜涘叾浠栧父鐢ㄧ殑鏂规硶锛屽offer()銆?code>poll()銆?code>size()绛夈€備綘鍙互鏍规嵁鍏蜂綋闇€姹傛潵閫夋嫨浣跨敤銆?/li>

浣跨敤BlockingQueue鍙互寰堟柟渚垮湴瀹炵幇鐢熶骇鑰?娑堣垂鑰呮ā鍨嬶紝鐢熶骇鑰呭皢鏁版嵁鏀惧叆闃熷垪涓紝娑堣垂鑰呬粠闃熷垪涓彇鍑烘暟鎹繘琛屽鐞嗐€傜敱浜嶣lockingQueue鐨勭嚎绋嬪畨鍏ㄦ€э紝鎴戜滑涓嶉渶瑕佹墜鍔ㄥ悓姝ユ搷浣溿€?/p>