java - Jetlang PoolFiber 示例

Question

我从 jetlang 开始基本样本非常清楚。 我没有找到使用 PoolFiber 的好示例。有人玩过 已经有了？我也阅读了 retlang 样本，但那里似乎有点不同。

感谢分享您的想法!

大神

Answer 1

PoolFiber 和 ThreadFiber 的使用几乎相同。唯一的区别是线程池需要初始化并用于创建每个 PoolFiber。

// create java thread pool.
ExecutorService pool = Executors.newCachedThreadPool();
//initialize factory with backing pool
PoolFiberFactory fiberFactory = new PoolFiberFactory(pool);
Fiber fiber = fiberFactory.create();
fiber.start();
//use fiber for normal publishing and subscribing.