Jetlang PoolFiber образец

Question

Я начал с jetlang , и основные образцы довольно ясны. Чего я не нашел, так это хорошего примера использования PoolFiber. Кто-нибудь играл с этим уже? Я читал также примеры ретланга, но там, кажется, немного по-другому.

Спасибо, что поделились своими мыслями!

Okami

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.

Answer 2

Лучший пул, чем Cache, включает в себя количество ядер ЦП, связанных с JVM:

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);

---

Answer 3

Вот это на Github.

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

Вот сайт mvn http://jetlang.github.io/jetlang/