ExecutorService находится в состоянии выключения в Redisson - PullRequest
Новая
       15

ExecutorService находится в состоянии выключения в Redisson

0 голосов
/ 05 ноября 2019

Я использую Redisson ExecutorService в kotlin, но возникает исключение, например: «java.util.concurrent.RejectedExecutionException: Задача отклонена. ExecutorService находится в состоянии выключения». 

class RunnableTask : Runnable ,Serializable{
   private val redissonClient: RedissonClient? = null
   private var param: Long=0

   override fun run() {
      val atomic = redissonClient!!.getAtomicLong("myAtomic")
      atomic.addAndGet(param)
      }

 }

fun main(args: Array<String>) {
  val config = Config()
  config.useSingleServer()
      .setAddress("redis://127.0.0.1:6379")
  val redisson = Redisson.create(config)

  val nodeConfig =   RedissonNodeConfig(config)   

  nodeConfig.setExecutorServiceWorkers(Collections.singletonMap("myExecutor", 1))
  val node = RedissonNode.create(nodeConfig)
  node.start()
  val e = redisson.getExecutorService("myExecutor")
  e.execute(  RunnableTask())
  e.shutdown()
  node.shutdown()

}

Я использую Redisson 3.110,5.

...