技术问答java涓璦rrayblockingqueue鎬庝箞浣跨敤 - 扬州沐宇科技

ArrayBlockingQueue鏄竴涓熀浜庢暟缁勭殑鏈夌晫闃诲闃熷垪锛屽畠鐨勫ぇ灏忔槸鍥哄畾鐨勶紝鍙互鍦ㄥ垵濮嬪寲鏃舵寚瀹氬閲忋€備笅闈㈡槸ArrayBlockingQueue鐨勫熀鏈娇鐢ㄦ柟娉曪細

ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(10);

queue.put("element"); // 灏嗗厓绱犳坊鍔犲埌闃熷垪涓紝濡傛灉闃熷垪宸叉弧浼氶樆濉炵瓑寰?/span>

String element = queue.take(); // 浠庨槦鍒椾腑鑾峰彇鍏冪礌锛屽鏋滈槦鍒椾负绌轰細闃诲绛夊緟

int size = queue.size(); // 鑾峰彇闃熷垪涓殑鍏冪礌涓暟

boolean isEmpty = queue.isEmpty(); // 鍒ゆ柇闃熷垪鏄惁涓虹┖

boolean isFull = queue.remainingCapacity() == 0; // 鍒ゆ柇闃熷垪鏄惁宸叉弧

闇€瑕佹敞鎰忕殑鏄紝鍦ㄤ娇鐢ˋrrayBlockingQueue鏃讹紝put鍜宼ake鏂规硶浼氶樆濉炲綋鍓嶇嚎绋嬶紝鐩村埌闃熷垪鏈夌┖闂存坊鍔犲厓绱犳垨鑰呮湁鍏冪礌鍙互琚彇鍑恒€傚彲浠ユ牴鎹叿浣撲笟鍔￠渶姹備娇鐢ㄤ笉鍚岀殑鏂规硶鏉ュ鐞嗛槦鍒椾腑鐨勫厓绱犮€?/p>