Package generic.concurrent

Class ConcurrentQBuilder<I,​R>

  • Type Parameters:
    I - The type of the items to be processed.
    R - The type of objects resulting from processing an item
    public class ConcurrentQBuilder<I,​R>
extends java.lang.Object
    A helper class to build up the potentially complicated ConcurrentQ.

    Note: you must supply either a GThreadPool instance or a thread pool name. Further, if you supply the name of a thread pool, then a private, non-shared pool will be used. If you wish to make use of a shared pool, then you need to create that thread pool yourself. See GThreadPool.getSharedThreadPool(String).

    Examples: 

     QCallback callback = new AbstractQCallback() {
     public R process(I item, TaskMonitor monitor) {
         // do work here...
     }
 };
 
 ConcurrentQBuilder builder = new ConcurrentQBuilder();
 builder.setThreadPoolName("Thread Pool Name");
 builder.setQueue(new PriorityBlockingQueue());
 concurrentQ = builder.build(callback);
 
 // OR, you can chain the builder calls:
 ConcurrentQBuilder builder = new ConcurrentQBuilder();
 queue = builder.setThreadPoolName("Thread Pool Name").
                                setQueue(new PriorityBlockingQueue()).
                                setMaxInProgress(1).
                                build(callback);

    Note: if you wish to take advantage of blocking when adding items to the ConcurrentQ, see setQueue(Queue).

    • Constructor Detail

      • ConcurrentQBuilder

        public ConcurrentQBuilder()

    • Method Detail

      • setQueue

        public ConcurrentQBuilder<I,​R> setQueue​(java.util.Queue<I> queue)
        Sets the queue to be used by the ConcurrentQ. If you would like advanced features, like a queue that blocks when too many items have been placed in it, then use an advanced queue here, such as a LinkedBlockingQueue.

        Note: if you wish to take advantage of blocking when adding items to the ConcurrentQ, then be sure to call the appropriate method, such as ConcurrentQ.offer(java.util.Iterator).

        Parameters:
        queue - the queue to be used by the ConcurrentQ
        Returns:
        this builder

      • setMaxInProgress

        public ConcurrentQBuilder<I,​R> setMaxInProgress​(int max)
        Specifies the maximum number of items that can be process at a time. If this is set to 0, then the concurrent queue will attempt to execute as many items at a time as there are threads in the given threadPool. Setting this parameter to 1 will have the effect of guaranteeing that all times are processed one at a time in the order they were submitted. Any other positive value will run that many items concurrently, up to the number of available threads.
        Parameters:
        max - the max number of items to execute at one time; defaults to 0
        Returns:
        this builder instance

      • setCollectResults

        public ConcurrentQBuilder<I,​R> setCollectResults​(boolean collectResults)
        Specifies if the concurrent queue should collect the results as items are processed so they can be returned in a ConcurrentQ.waitForResults() call.
        Parameters:
        collectResults - true signals to collect the generated results; defaults to false
        Returns:
        this builder instance

      • setJobsReportProgress

        public ConcurrentQBuilder<I,​R> setJobsReportProgress​(boolean reportsProgress)
        True signals that the jobs run by the client wish to report progress. The default value is false.

        The default of false is good for clients that have a known amount of work to be processed. In this case, a total count of work jobs is maintained by the queue. As items are completed, the queue will update the monitor provided to it at construction time to reflect the number of jobs completed as work is done. On the other hand, some clients have known known number of jobs to complete, but simply add work to the queue as it arrives. In that case, the client should update its monitor for progress, as the queue cannot do so in a meaningful way.

        Parameters:
        reportsProgress - true signals that the client will update progress; false signals that the queue should do so
        Returns:
        this builder instance

      • setCancelClearsAllJobs

        public ConcurrentQBuilder<I,​R> setCancelClearsAllJobs​(boolean clearAllJobs)