5

我似乎在这里遇到了两个问题之一。要么像这样的错误：

java.lang.IllegalStateException: Event bus [Bus "default"] accessed from non-main thread Looper

或者，如果我设法“解决”了这个问题，我根本就不会在我的订阅者中收到该事件。

目前，我有一个类，从几个来源拼凑而成，对 Bus 进行子分类：

public class MainThreadBus extends Bus {
    private static Bus _bus;
    private Handler _handler = new Handler(Looper.getMainLooper());

    public MainThreadBus() {
        if (_bus == null) {
            _bus = new Bus();
        }
    }

    @Override public void register(Object obj) {
        _bus.register(obj);
    }

    @Override public void unregister(Object obj) {
        _bus.unregister(obj);
    }

    @Override public void post(final Object event) {
        if (Looper.myLooper() == Looper.getMainLooper()) {
            _bus.post(event);
        } else {
            _handler.post(new Runnable() {
                @Override public void run() {
                    _bus.post(event);
                }
            });
        }
    }
}

在这样的活动中使用：

@Subscribe
public void requestProgressAvailable(RESTRequestProgress progress) {
    processProgress(progress);
}

@Override
protected void onResume() {
    super.onResume();

    _bus = new MainThreadBus();
    _bus.register(this);
}

@Override
protected void onPause() {
    super.onPause();

    _bus = new MainThreadBus();
    _bus.unregister(this);
}

并像这样从 IntentService 发布：

_bus = new MainThreadBus();
_bus.post(request.createRESTRequestProgress(RESTRequest.STATUS_STARTED));

并且没有收到消息。另一个配置让我收到线程错误，所以我现在就这样做。

那么，我错过了什么，或者做错了什么？

编辑：感谢下面的 Andy 指出我的代码没有像我想象的那样运行。上面的代码现在反映了基于该反馈的修改。

4

2 回答 2

8

除了这个实现不是单例之外，当得到这个错误时，你可以在构造函数中使用 threadEnforcer.ANY 选项：

private static final Bus BUS = new Bus(ThreadEnforcer.ANY);
于 2015-04-09T13:35:45.047 回答
3

问题是您的代码没有与同一个总线实例交互。您应该访问相同的总线，例如从工厂或通过注入获得的单例，而不是在每种情况下都创建新的 MainThreadBus。

于 2013-07-03T23:27:33.910 回答