final EventLoops eventLoops = new NioEventLoops(new EventPolicy(),3);
ClientPolicy cp = new ClientPolicy();
cp.eventLoops = eventLoops;
cp.maxConnsPerNode = maxConnsPerNode;
Host host = new Host("127.0.0.1", 3000);		
IAerospikeClient client = new AerospikeClient(cp, host);

cp.eventLoops = eventLoops;
指定 eventLoops
		
client.get(AsClientUtil.nextEventLoop(), new RecordListenerImpl(), new QueryPolicy(), k);


private static class RecordListenerImpl implements RecordListener {
    public void onSuccess(Key key, Record record) {
        System.out.println("onSuccess,key=" + key + ",record=" + record);
    }
    public void onFailure(AerospikeException exception) {
        System.out.println("onFailure," + exception);
    }
}


完整代码
https://gitee.com/dyyx/asdemo/blob/master/src/main/java/demo/SyncAndAsyncTest.java