Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // 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.
Add Comment
Please, Sign In to add comment