当前位置：文江博客话题详情

多线程应用程序中的事件处理

发布于 2024-11-03 02:56:52 字数 154 浏览 0 评论 0原文

我正在用 Java 设计一个独立的多线程应用程序。我正在尝试为他的项目选择最佳的事件处理解决方案。

我有 1-3 个线程生成事件（例如，通讯线程完成文件上传），而其他线程可能希望注册以获得有关此事件的通知。我希望事件生成和事件侦听尽可能分离。

你有什么建议？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

情释 2024-11-10 02:56:52

使用事件总线。

事件总线可以被认为是
替换观察者模式，
在观察者模式中，每个
组件正在观察一个可观察的
直接地。在事件总线模式中，
每个组件只需订阅
事件总线并等待其事件
要调用的通知方法
当有趣的事件发生时。
这样，事件总线就可以是
像观察者模式一样思考
具有额外的解耦层。

这是关于使用的演示 GWT 中的事件总线。它应该能让您很好地了解其好处（而且也很有趣）。

编辑

第一个链接主要作为示例给出。自己实现类似的适合您需求的东西实际上并不难。

回复收藏 0 原文

笑红尘 2024-11-10 02:56:52

我会使用 ExecutorServices 来管理您的线程池。这样，当您有事件的侦听器时，您可以确保使用代理或手动编码将事件添加到正确的服务。例如，

public void onEventOne(final Type parameter) {
    executorService.submit(new Runnable() {
        public void run() {
            wrappedListener.onEventOne(parameter);
        }
    }
}

您可以将此侦听器包装器传递为并确保将使用所需的线程池处理该事件。

使用代理可以避免这种类型的样板代码。 ;)

I would use ExecutorServices to manage your thread pools. This way when you have a listener to an event, you can ensure the event is added to the right service either using a Proxy, or hande coded. e.g.

public void onEventOne(final Type parameter) {
    executorService.submit(new Runnable() {
        public void run() {
            wrappedListener.onEventOne(parameter);
        }
    }
}

You can pass this listener wrapper as and be sure the event will be processed using the desired thread pool.

Using a Proxy allows you to avoid this type of boiler plate code. ;)

回复收藏 0 原文