有时当我调试我的应用程序时,我在RxCachedThreadScheduler-1中遇到InterruptedException.这是跟踪：

Fatal Exception: java.lang.InterruptedException

at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:1991)

at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2025)

at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1048)

at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:776)

at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1035)

我有一个自定义视图,我在其中订阅我的observable,如下所示：

@Override

protected void onAttachedToWindow() {

super.onAttachedToWindow();

sub = FollowHandler.getInstance().getObservable()

.filter(new Func1() {

@Override

public Boolean call(FollowEvent followEvent) {

if(followEvent == null || followEvent.user == null

|| user == null)

return false;

return followEvent.user.id == user.id;

}

})

.observeOn(AndroidSchedulers.mainThread())

.subscribe(new Observer() {

@Override

public void onCompleted() {}

@Override

public void onError(Throwable e) {}

@Override

public void onNext(FollowEvent followEvent) {

reactToThisNiceEvent(followEvent);

}

});

}

@Override

protected void onDetachedFromWindow() {

super.onDetachedFromWindow();

if(sub != null)

sub.unsubscribe();

}

这是可观察的：

eventSubject.asObservable()

.observeOn(Schedulers.io())

.doOnNext(new Action1() {

@Override

public void call(FollowEvent followEvent) {

if(followEvent != null)

doSomethingNice(followEvent);

}

})

.share();

其中eventSubject是一个简单的PublishSubject.

我使用RxAndroid 1.1.0和RxJava 1.1.0.

有谁知道为什么会这样？