uli
05/09/2017, 11:51 AMobject : CacheLoader<String, Int>() {
override fun load(key: String): Int {
return runBlocking(krawlerPool) {
pushLock.lock()
try { pushSelector++ % queues.size }
finally {pushLock.unlock()}
}
}
}