Aerospike Java异步库似乎卡住了

我正在使用aeropike异步客户端执行udf。客户端已被初始化为： -Aerospike Java异步库似乎卡住了

try { 
     asyncClientPolicy.maxThreads = 40; 
     asyncClientPolicy.asyncMaxCommands = 20; 
     asyncClientPolicy.maxSocketIdle = 13; 
     asyncClientPolicy.asyncMaxCommandAction = MaxCommandAction.BLOCK; 
     asyncClientPolicy.asyncSelectorThreads = 7; 
     asyncClientPolicy.asyncTaskThreadPool = Executors.newFixedThreadPool(20, new ThreadFactory() { 
      public final Thread newThread(Runnable runnable) { 
       Thread thread = new Thread(runnable); 
       thread.setDaemon(true); 
       return thread; 
      } 
     }); 
    }

所以我有20个线程来处理回调。过了一段时间，我发现我的程序没有取得任何进展，表明僵局/饥饿。 Jstack给了我下面的结果： -

java.lang.Thread.State: WAITING (parking) 
    at sun.misc.Unsafe.park(Native Method) 
    - parking to wait for <0x000000064048f338> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) 
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186) 
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043) 
    at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:374) 
    at com.aerospike.client.async.AsyncCluster$BlockBufferQueue.getByteBuffer(AsyncCluster.java:114) 
    at com.aerospike.client.async.AsyncCluster.getByteBuffer(AsyncCluster.java:68) 
    at com.aerospike.client.async.AsyncCommand.execute(AsyncCommand.java:59) 
    at com.aerospike.client.async.AsyncClient.execute(AsyncClient.java:949) 
    at main.java.labs.RuleEngineAerospikeConnection.updatePositiveSegmentsUDF(RuleEngineAerospikeConnection.java:217) 
    at main.java.labs.Segment$ProductChecker.onSuccess(Segment.java:346) 
    at com.aerospike.client.async.AsyncRead.onSuccess(AsyncRead.java:149) 
    at com.aerospike.client.async.AsyncCommand.finish(AsyncCommand.java:293) 
    at com.aerospike.client.async.AsyncSingleCommand.read(AsyncSingleCommand.java:59) 
    at com.aerospike.client.async.AsyncCommand.run(AsyncCommand.java:261) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
    at java.lang.Thread.run(Thread.java:745)

我在等待状态都在execute命令正好20个线程。我是否做了错误的设置，因为我期望客户端返回，即使在我的UDF中有任何异常，如果有无限循环会发生什么？它会导致这种行为吗？

来源

2017-07-25 Mangat Rai Modi

更改为同步客户端解决了问题 –

如果没有查看源代码，很难说是什么导致了死锁。你的AsyncClientPolicy看起来足够了。

无论如何，自从version 4以来，旧的AsyncClient类已经过时。 AerospikeClient类现在包含新的异步方法，其执行速度必须比旧的AsyncClient快。新的异步方法也支持Netty事件循环，并始终以非阻塞模式运行。

来源

2017-07-27 00:34:45 Brian

感谢Brian，我会尽力而为。它看起来像一个错误，其中asyncTaskThreadPool正在等待任务到达并阻止执行函数调用。它快速地在4.0中解决。我会尽快更新 –

Aerospike Java异步库似乎卡住了

回答

相关问题