net.jimblackler.Utils

Class ThreadedYieldAdapter<T>

java.lang.Object

net.jimblackler.Utils.ThreadedYieldAdapter<T>

All Implemented Interfaces:

YieldAdapter<T>

public class ThreadedYieldAdapter<T>
extends java.lang.Object
implements YieldAdapter<T>

A class to convert methods that implement the Collector<> class into a standard Iterable<>, using a new thread created for the collection process, and a SynchronousQueue<> object.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	ThreadedYieldAdapter.Message Message structure to pass values between threads.
(package private) class	ThreadedYieldAdapter.ValueMessage The vehicle to pass the actual values.

Constructor Summary

Constructors

Constructor and Description
ThreadedYieldAdapter()

Method Summary

Modifier and Type	Method and Description
YieldAdapterIterable<T>	adapt(Collector<T> client) Convert a method that implements the Collector<> class with a standard Iterable<>.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThreadedYieldAdapter

public ThreadedYieldAdapter()

Method Detail

adapt

public YieldAdapterIterable<T> adapt(Collector<T> client)

Convert a method that implements the Collector<> class with a standard Iterable<>. This means that the collecting method can use complex recursive logic, but still allows the calling code to handle the results with a standard iterator. Results are returned immediately and do not incur overhead of being stored in a list. Calculation overhead is only performed for the results that are requested through the iterator. This is implemented using a new thread created for the collection process, and a SynchronousQueue<> object.

Specified by:

adapt in interface YieldAdapter<T>