首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >如何从scala伙伴对象获取AtomicReferenceFieldUpdater?

如何从scala伙伴对象获取AtomicReferenceFieldUpdater?
EN

Stack Overflow用户
提问于 2011-04-07 08:28:41
回答 2查看 829关注 0票数 5

如果我在某个集合结构中有一个链接的节点,我不希望它的下一个链接是AtomicReference (我需要原子CAS update),所以我将其声明为:

代码语言:javascript
复制
@volatile var next: Node[A] = _n

然后在伴奏中声明:

代码语言:javascript
复制
val updater = AtomicReferenceFieldUpdater.newUpdater(classOf[Link[_]], classOf[Node[_]], "n")
def cas[A](target: Link[A], old: Node[A], newNode: Node[A]) = updater.compareAndSet(target, old, newNode);

在运行时,我得到以下错误:

代码语言:javascript
复制
java.lang.RuntimeException: java.lang.IllegalAccessException: 
  Class concurrent.Link$ can not access a member of class concurrent.Link
  with modifiers "private volatile"
    at java.util.concurrent.atomic.AtomicReferenceFieldUpdater$AtomicReferenceFieldUpdaterImpl.<init>(AtomicReferenceFieldUpdater.java:189)
    at java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater(AtomicReferenceFieldUpdater.java:65)
    at concurrent.Link$.<init>(Link.scala:106)
    ...

因此,在运行时,伴随对象是concurrent.Link$而不是concurrent.Link,不同的类不能访问另一个类的私有成员。

但是,如果我javap -p concurrent.Link

我得到了:

代码语言:javascript
复制
Compiled from "Link.scala"
public final class concurrent.Link implements concurrent.Node,scala.ScalaObject,scala.Product,java.io.Serializable{
private final java.lang.Object value;
private volatile com.atlassian.util.scala.concurrent.Node node;
public static final boolean cas(com.atlassian.util.scala.concurrent.Link, com.atlassian.util.scala.concurrent.Node, com.atlassian.util.scala.concurrent.Node);
public static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater updater();

因此,除了在我的Link类上声明的AtomicReferenceFieldUpdater的静态实例之外,我已经拥有了所有东西。

问题是,如何在Scala中获得指向易失性变量的AtomicReferenceFieldUpdater实例?

到目前为止,我找到的唯一方法是回到Java语言(用next Node域和静态AtomicReferenceFieldUpdater实现一个AbstractLink )并继承它,这很难看。

EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2011-05-27 13:54:07

有人告诉我,在纯scala中无法做到这一点,你需要在Java中定义一个类来做到这一点。幸运的是,交叉编译非常简单,但仍然很烦人!

票数 0
EN

Stack Overflow用户

发布于 2011-04-08 02:48:25

太难了。因为Scala使字段成为私有的,并且只有访问器方法可用,所以这可能是不可能的。

在执行此操作时,我最终决定通过使用volatile字段创建Java基类并在其中进行更新来完成此操作。

Java文件:

代码语言:javascript
复制
public class Base {
   volatile Object field = null;
}

Scala文件:

代码语言:javascript
复制
class Cls extends Base {
  val updater = AtomicReferenceFieldUpdater.newUpdater(classOf[Base[_]], classOf[Object[_]], "field")
  def cas[A](old: Object, n: Object) = updater.compareAndSet(this, old, n);
}

我还没有想出一个不同的方法。

票数 4
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/5574502

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档