public final void tryFlushAll ( ) { if ( flushing . compareAndSet ( false , true ) ) { if ( reset ) { for ( Stat stat : Stat . values ( ) ) { topKeyWrapper . get ( stat ) . reset ( this , capacity ) ; } reset = false ; } else { for ( Stat stat : Stat . values ( ) ) { topKeyWrapper . get ( stat ) . flush ( ) ; } } flushing . set ( false ) ; } }
Tries to flush all the enqueue offers to be visible globally .