@ GuardedBy ( "evictionLock" ) void drainReadBuffers ( ) { final int start = ( int ) Thread . currentThread ( ) . getId ( ) ; final int end = start + NUMBER_OF_READ_BUFFERS ; for ( int i = start ; i < end ; i ++ ) { drainReadBuffer ( i & READ_BUFFERS_MASK ) ; } }
Drains the read buffers each up to an amortized threshold .