我在kotlin中使用redisson ExecutorService,但是发生了这样的异常,“ 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.11.5。