while ((! CHANGE_LOGS.isEmpty()) && (CHANGE_LOGS.peek().txNumber <= txNumber)) { CHANGE_LOGS.poll();
synchronized (CHANGE_LOGS) { while ((! CHANGE_LOGS.isEmpty()) && (CHANGE_LOGS.peek().txNumber <= txNumber)) { ChangeLogSet clSet = CHANGE_LOGS.poll(); }
    public static void cleanOldLogs(int txNumber) {	while ((! CHANGE_LOGS.isEmpty()) && (CHANGE_LOGS.peek().txNumber <= txNumber)) {	    CHANGE_LOGS.poll();	}    }