我有一个REST客户端,该客户端正在接收JSON对象。该客户端在自己的线程中工作,并且该对象每秒大约更新10次。
现在,主类(创建线程)应该能够对指定线程对象的更改做出反应。ChangeListener是最有用的方法吗?我的问题是将Listener与thread变量组合在一起。我只知道如何提供线程安全的变量获取器,但这现在无济于事。有没有人举过一个例子,如何从另一个线程观察这样的值?
处理所有值并不是很重要。(json对象包含位置数据)之后,主类应使用该数据来模拟鼠标移动,但这与问题无关。
谢谢大家的帮助!
ChangeListener是最好,最简单的方法,但不是唯一的方法。您还可以使用wait / notifyall观察者模式。您可以使用一些易失性标志将线程变量与侦听器分开,在比较新收到的jason字符串与当前jason字符串时可以更新该变量。我附加了一个虚拟代码,可能会有所帮助:
import java.util.*;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicReference;
public class ChangeManager{
private Set<ChangeListener> listenerSet = new HashSet<ChangeListener>();
private volatile boolean stateChanged;
private Timer timer = new Timer();
private AtomicReference<MyJasonObject> currentJasonObjectState = new AtomicReference<MyJasonObject>();
public void start(){
timer.scheduleAtFixedRate(new TimerTask() {
@Override
public void run() {
monitorValue();
}
}, 0, 1000);
}
public void monitorValue(){
// Make Rest call and check if Jason object has changed and so update the stateChanged flag.
stateChanged = hasStateChange();
if(stateChanged){
Iterator<ChangeListener> i = listenerSet.iterator();
while(i.hasNext()) {
i.next().notifyListener();
}
stateChanged = false;
}
}
public void addListener(ChangeListener listener){
listenerSet.add(listener);
}
public void removeListener(ChangeListener listener){
listenerSet.remove(listener);
}
}
interface ChangeListener {
void notifyListener();
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句