in src/main/java/org/apache/activemq/artemis/nativo/jlibaio/util/CallbackCache.java [41:59]
public Callback get() {
synchronized (lock) {
if (available <= 0) {
return null;
} else {
Callback retValue = (Callback) pool[get];
pool[get] = null;
if (retValue == null) {
throw new NullPointerException("You should initialize the pool before using it");
}
available--;
get++;
if (get >= size) {
get = 0;
}
return retValue;
}
}
}