我试图通过调用session.executeAsync()代替session.execute()DB写入来加速我们的代码.
我们有数据库连接可能已关闭的用例,当前之前execute()在连接丢失时抛出异常(集群中没有主机可访问).我们可以捕获这些异常,并在其他地方重试或保存数据等...
有了executeAsync(),它看起来没有任何方法来实现这个用例 - ResultSetFuture需要访问返回的对象来检查结果,这将失去executeAsync()首先使用的目的...
有没有办法在executeAsync()调用的任何地方添加一个监听器(或类似的东西),它会异步通知一些其他代码,因为DB写入失败了？
这是相关的吗？Datastax 1.0.2 Java 1.7.40
使用 Java 1.6 和 AtomicLongArray，我想将原始 AtomicLongArray “复制”到一个新的 AtomicLongArray 中。有一个构造函数接受一个数组 (AtomicLongArray(long[]))，所以我想我可以从原始数组中获取数组并将其提供给构造函数。
可悲的是， AtomicLongArray 中的实际 long[] 是私有的，似乎没有吸气剂。有没有办法做到这一点，这意味着将值从一个 AtomicLongArray 复制到另一个？我无法基于这个类创建自己的类，因为 sun.misc.Unsafe 类对我不可用。
这是必需的，因为我将迭代这些值，并且我不希望它们在迭代过程中被另一个线程修改。所以我想我可以制作一个副本并将其用于迭代......
谢谢！菲利普