ArrayBlockingQueue是concurrent包提供的一个线程安全的队列,由一个数组来保存队列元素.通过takeIndex和putIndex来分别记录出队列和入队列的下标,以保证在出队列时不进行元素移动.//在出队列或者入队列的时候对takeIndex或者putIndex进行累加,如果已经到了数组末尾就又从0开始,保证数组的循环使用.finalintinc(inti){return(++i==items.length)?0:i;}//入队列操作privatevoidinsert...
查看全文