1

我从jetlang开始,基本示例非常清晰。我没有找到使用 PoolFiber 的好示例。有人玩过吗?我还阅读了 retlang 示例,但那里似乎有点不同。

感谢您分享您的想法!

大神

4

3 回答 3

5

使用 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.
于 2008-11-23T05:27:44.853 回答
0

这是在 Github 上。

https://github.com/jetlang/jetlang/blob/readme/src/test/java/org/jetlang/examples/BasicExamples.java

这是 mvn 网站 http://jetlang.github.io/jetlang/

于 2014-04-05T08:15:57.667 回答
0

比 Cache 更好的池是涉及与 JVM 相关的 CPU 核心数量:

int availableProcessors = Runtime.getRuntime().availableProcessors();
int threadPoolSize = availableProcessors*2;
ThreadPoolExecutor POOL = new ThreadPoolExecutor(threadPoolSize,
    threadPoolSize, 0L, TimeUnit.MILLISECONDS,  
    new LinkedBlockingQueue<Runnable>());
PoolFiberFactory fiberFactory = new PoolFiberFactory(POOL);

于 2015-05-22T08:48:30.380 回答