blitz_stable: src/EDU/oswego/cs/dl/util/concurrent/FJTaskRunnerGroup.java annotate

annotate src/EDU/oswego/cs/dl/util/concurrent/FJTaskRunnerGroup.java @ 27:511648fa4d64 Version 2.1

Version to 2.1

author	Dan Creswell <dan.creswell@gmail.com>
date	Mon, 04 Jan 2010 13:00:40 +0000
parents	3dc0c5604566
children

rev	line source
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	1 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	2 File: FJTaskRunnerGroup.java
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	3
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	4 Originally written by Doug Lea and released into the public domain.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	5 This may be used for any purposes whatsoever without acknowledgment.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	6 Thanks for the assistance and support of Sun Microsystems Labs,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	7 and everyone contributing, testing, and using this code.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	8
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	9 History:
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	10 Date Who What
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	11 7Jan1999 dl First public release
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	12 12Jan1999 dl made getActiveCount public; misc minor cleanup.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	13 14Jan1999 dl Added executeTask
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	14 20Jan1999 dl Allow use of priorities; reformat stats
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	15 6Feb1999 dl Lazy thread starts
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	16 27Apr1999 dl Renamed
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	17 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	18
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	19 package EDU.oswego.cs.dl.util.concurrent;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	20
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	21 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	22 * A stripped down analog of a ThreadGroup used for
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	23 * establishing and managing FJTaskRunner threads.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	24 * ThreadRunnerGroups serve as the control boundary separating
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	25 * the general world of normal threads from the specialized world
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	26 * of FJTasks.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	27 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	28 * By intent, this class does not subclass java.lang.ThreadGroup, and
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	29 * does not support most methods found in ThreadGroups, since they
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	30 * would make no sense for FJTaskRunner threads. In fact, the class
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	31 * does not deal with ThreadGroups at all. If you want to restrict
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	32 * a FJTaskRunnerGroup to a particular ThreadGroup, you can create
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	33 * it from within that ThreadGroup.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	34 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	35 * The main contextual parameter for a FJTaskRunnerGroup is
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	36 * the group size, established in the constructor.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	37 * Groups must be of a fixed size.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	38 * There is no way to dynamically increase or decrease the number
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	39 * of threads in an existing group.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	40 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	41 * In general, the group size should be equal to the number
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	42 * of CPUs on the system. (Unfortunately, there is no portable
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	43 * means of automatically detecting the number of CPUs on a JVM, so there is
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	44 * no good way to automate defaults.) In principle, when
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	45 * FJTasks are used for computation-intensive tasks, having only
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	46 * as many threads as CPUs should minimize bookkeeping overhead
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	47 * and contention, and so maximize throughput. However, because
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	48 * FJTaskRunners lie atop Java threads, and in turn operating system
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	49 * thread support and scheduling policies,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	50 * it is very possible that using more threads
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	51 * than CPUs will improve overall throughput even though it adds
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	52 * to overhead. This will always be so if FJTasks are I/O bound.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	53 * So it may pay to experiment a bit when tuning on particular platforms.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	54 * You can also use <code>setRunPriorities</code> to either
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	55 * increase or decrease the priorities of active threads, which
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	56 * may interact with group size choice.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	57 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	58 * In any case, overestimating group sizes never
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	59 * seriously degrades performance (at least within reasonable bounds).
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	60 * You can also use a value
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	61 * less than the number of CPUs in order to reserve processing
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	62 * for unrelated threads.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	63 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	64 * There are two general styles for using a FJTaskRunnerGroup.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	65 * You can create one group per entire program execution, for example
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	66 * as a static singleton, and use it for all parallel tasks:
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	67 * <pre>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	68 * class Tasks {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	69 * static FJTaskRunnerGroup group;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	70 * public void initialize(int groupsize) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	71 * group = new FJTaskRunnerGroup(groupSize);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	72 * }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	73 * // ...
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	74 * }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	75 * </pre>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	76 * Alternatively, you can make new groups on the fly and use them only for
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	77 * particular task sets. This is more flexible,,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	78 * and leads to more controllable and deterministic execution patterns,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	79 * but it encounters greater overhead on startup. Also, to reclaim
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	80 * system resources, you should
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	81 * call <code>FJTaskRunnerGroup.interruptAll</code> when you are done
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	82 * using one-shot groups. Otherwise, because FJTaskRunners set
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	83 * <code>Thread.isDaemon</code>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	84 * status, they will not normally be reclaimed until program termination.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	85 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	86 * The main supported methods are <code>execute</code>,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	87 * which starts a task processed by FJTaskRunner threads,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	88 * and <code>invoke</code>, which starts one and waits for completion.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	89 * For example, you might extend the above <code>FJTasks</code>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	90 * class to support a task-based computation, say, the
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	91 * <code>Fib</code> class from the <code>FJTask</code> documentation:
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	92 * <pre>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	93 * class Tasks { // continued
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	94 * // ...
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	95 * static int fib(int n) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	96 * try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	97 * Fib f = new Fib(n);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	98 * group.invoke(f);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	99 * return f.getAnswer();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	100 * }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	101 * catch (InterruptedException ex) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	102 * throw new Error("Interrupted during computation");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	103 * }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	104 * }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	105 * }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	106 * </pre>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	107 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	108 * Method <code>stats()</code> can be used to monitor performance.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	109 * Both FJTaskRunnerGroup and FJTaskRunner may be compiled with
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	110 * the compile-time constant COLLECT_STATS set to false. In this
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	111 * case, various simple counts reported in stats() are not collected.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	112 * On platforms tested,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	113 * this leads to such a tiny performance improvement that there is
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	114 * very little motivation to bother.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	115 *
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	116 * <p>[<a href="http://gee.cs.oswego.edu/dl/classes/EDU/oswego/cs/dl/util/concurrent/intro.html"> Introduction to this package. </a>]
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	117 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	118 * @see FJTask
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	119 * @see FJTaskRunner
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	120 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	121
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	122 public class FJTaskRunnerGroup implements Executor {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	123
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	124 / The threads in this group /
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	125 protected final FJTaskRunner[] threads;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	126
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	127 / Group-wide queue for tasks entered via execute() /
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	128 protected final LinkedQueue entryQueue = new LinkedQueue();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	129
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	130 / Number of threads that are not waiting for work /
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	131 protected int activeCount = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	132
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	133 /** Number of threads that have been started. Used to avoid
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	134 unecessary contention during startup of task sets.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	135 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	136 protected int nstarted = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	137
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	138 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	139 * Compile-time constant. If true, various counts of
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	140 * runs, waits, etc., are maintained. These are NOT
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	141 * updated with synchronization, so statistics reports
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	142 * might not be accurate.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	143 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	144
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	145 static final boolean COLLECT_STATS = true;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	146 // static final boolean COLLECT_STATS = false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	147
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	148 // for stats
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	149
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	150 / The time at which this ThreadRunnerGroup was constructed /
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	151 long initTime = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	152
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	153 / Total number of executes or invokes /
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	154 int entries = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	155
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	156 static final int DEFAULT_SCAN_PRIORITY = Thread.MIN_PRIORITY+1;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	157
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	158 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	159 * Create a FJTaskRunnerGroup with the indicated number
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	160 * of FJTaskRunner threads. Normally, the best size to use is
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	161 * the number of CPUs on the system.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	162 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	163 * The threads in a FJTaskRunnerGroup are created with their
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	164 * isDaemon status set, so do not normally need to be
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	165 * shut down manually upon program termination.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	166 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	167
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	168 public FJTaskRunnerGroup(int groupSize) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	169 threads = new FJTaskRunner[groupSize];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	170 initializeThreads();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	171 initTime = System.currentTimeMillis();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	172 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	173
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	174 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	175 * Arrange for execution of the given task
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	176 * by placing it in a work queue. If the argument
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	177 * is not of type FJTask, it is embedded in a FJTask via
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	178 * <code>FJTask.Wrap</code>.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	179 * @exception InterruptedException if current Thread is
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	180 * currently interrupted
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	181 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	182
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	183 public void execute(Runnable r) throws InterruptedException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	184 if (r instanceof FJTask) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	185 entryQueue.put((FJTask)r);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	186 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	187 else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	188 entryQueue.put(new FJTask.Wrap(r));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	189 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	190 signalNewTask();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	191 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	192
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	193
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	194 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	195 * Specialized form of execute called only from within FJTasks
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	196 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	197 public void executeTask(FJTask t) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	198 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	199 entryQueue.put(t);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	200 signalNewTask();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	201 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	202 catch (InterruptedException ex) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	203 Thread.currentThread().interrupt();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	204 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	205 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	206
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	207
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	208 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	209 * Start a task and wait it out. Returns when the task completes.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	210 * @exception InterruptedException if current Thread is
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	211 * interrupted before completion of the task.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	212 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	213
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	214 public void invoke(Runnable r) throws InterruptedException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	215 InvokableFJTask w = new InvokableFJTask(r);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	216 entryQueue.put(w);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	217 signalNewTask();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	218 w.awaitTermination();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	219 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	220
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	221
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	222 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	223 * Try to shut down all FJTaskRunner threads in this group
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	224 * by interrupting them all. This method is designed
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	225 * to be used during cleanup when it is somehow known
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	226 * that all threads are idle.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	227 * FJTaskRunners only
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	228 * check for interruption when they are not otherwise
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	229 * processing a task (and its generated subtasks,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	230 * if any), so if any threads are active, shutdown may
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	231 * take a while, and may lead to unpredictable
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	232 * task processing.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	233 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	234
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	235 public void interruptAll() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	236 // paranoically interrupt current thread last if in group.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	237 Thread current = Thread.currentThread();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	238 boolean stopCurrent = false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	239
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	240 for (int i = 0; i < threads.length; ++i) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	241 Thread t = threads[i];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	242 if (t == current)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	243 stopCurrent = true;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	244 else
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	245 t.interrupt();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	246 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	247 if (stopCurrent)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	248 current.interrupt();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	249 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	250
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	251
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	252 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	253 * Set the priority to use while a FJTaskRunner is
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	254 * polling for new tasks to perform. Default
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	255 * is currently Thread.MIN_PRIORITY+1. The value
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	256 * set may not go into effect immediately, but
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	257 * will be used at least the next time a thread scans for work.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	258 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	259 public synchronized void setScanPriorities(int pri) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	260 for (int i = 0; i < threads.length; ++i) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	261 FJTaskRunner t = threads[i];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	262 t.setScanPriority(pri);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	263 if (!t.active) t.setPriority(pri);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	264 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	265 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	266
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	267
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	268 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	269 * Set the priority to use while a FJTaskRunner is
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	270 * actively running tasks. Default
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	271 * is the priority that was in effect by the thread that
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	272 * constructed this FJTaskRunnerGroup. Setting this value
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	273 * while threads are running may momentarily result in
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	274 * them running at this priority even when idly waiting for work.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	275 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	276 public synchronized void setRunPriorities(int pri) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	277 for (int i = 0; i < threads.length; ++i) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	278 FJTaskRunner t = threads[i];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	279 t.setRunPriority(pri);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	280 if (t.active) t.setPriority(pri);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	281 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	282 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	283
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	284
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	285
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	286 / Return the number of FJTaskRunner threads in this group /
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	287
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	288 public int size() { return threads.length; }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	289
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	290
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	291 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	292 * Return the number of threads that are not idly waiting for work.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	293 * Beware that even active threads might not be doing any useful
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	294 * work, but just spinning waiting for other dependent tasks.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	295 * Also, since this is just a snapshot value, some tasks
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	296 * may be in the process of becoming idle.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	297 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	298 public synchronized int getActiveCount() { return activeCount; }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	299
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	300 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	301 * Prints various snapshot statistics to System.out.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	302 * <ul>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	303 * <li> For each FJTaskRunner thread (labeled as T<em>n</em>, for
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	304 * <em>n</em> from zero to group size - 1):
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	305 * <ul>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	306 * <li> A star "*" is printed if the thread is currently active;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	307 * that is, not sleeping while waiting for work. Because
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	308 * threads gradually enter sleep modes, an active thread
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	309 * may in fact be about to sleep (or wake up).
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	310 * <li> <em>Q Cap</em> The current capacity of its task queue.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	311 * <li> <em>Run</em> The total number of tasks that have been run.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	312 * <li> <em>New</em> The number of these tasks that were
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	313 * taken from either the entry queue or from other
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	314 * thread queues; that is, the number of tasks run
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	315 * that were <em>not</em> forked by the thread itself.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	316 * <li> <em>Scan</em> The number of times other task
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	317 * queues or the entry queue were polled for tasks.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	318 * </ul>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	319 * <li> <em>Execute</em> The total number of tasks entered
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	320 * (but not necessarily yet run) via execute or invoke.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	321 * <li> <em>Time</em> Time in seconds since construction of this
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	322 * FJTaskRunnerGroup.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	323 * <li> <em>Rate</em> The total number of tasks processed
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	324 * per second across all threads. This
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	325 * may be useful as a simple throughput indicator
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	326 * if all processed tasks take approximately the
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	327 * same time to run.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	328 * </ul>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	329 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	330 * Cautions: Some statistics are updated and gathered
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	331 * without synchronization,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	332 * so may not be accurate. However, reported counts may be considered
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	333 * as lower bounds of actual values.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	334 * Some values may be zero if classes are compiled
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	335 * with COLLECT_STATS set to false. (FJTaskRunner and FJTaskRunnerGroup
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	336 * classes can be independently compiled with different values of
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	337 * COLLECT_STATS.) Also, the counts are maintained as ints so could
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	338 * overflow in exceptionally long-lived applications.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	339 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	340 * These statistics can be useful when tuning algorithms or diagnosing
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	341 * problems. For example:
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	342 * <ul>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	343 * <li> High numbers of scans may mean that there is insufficient
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	344 * parallelism to keep threads busy. However, high scan rates
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	345 * are expected if the number
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	346 * of Executes is also high or there is a lot of global
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	347 * synchronization in the application, and the system is not otherwise
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	348 * busy. Threads may scan
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	349 * for work hundreds of times upon startup, shutdown, and
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	350 * global synch points of task sets.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	351 * <li> Large imbalances in tasks run across different threads might
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	352 * just reflect contention with unrelated threads on a system
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	353 * (possibly including JVM threads such as GC), but may also
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	354 * indicate some systematic bias in how you generate tasks.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	355 * <li> Large task queue capacities may mean that too many tasks are being
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	356 * generated before they can be run.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	357 * Capacities are reported rather than current numbers of tasks
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	358 * in queues because they are better indicators of the existence
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	359 * of these kinds of possibly-transient problems.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	360 * Queue capacities are
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	361 * resized on demand from their initial value of 4096 elements,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	362 * which is much more than sufficient for the kinds of
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	363 * applications that this framework is intended to best support.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	364 * </ul>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	365 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	366
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	367 public void stats() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	368 long time = System.currentTimeMillis() - initTime;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	369 double secs = ((double)time) / 1000.0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	370 long totalRuns = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	371 long totalScans = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	372 long totalSteals = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	373
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	374 System.out.print("Thread" +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	375 "\tQ Cap" +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	376 "\tScans" +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	377 "\tNew" +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	378 "\tRuns" +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	379 "\n");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	380
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	381 for (int i = 0; i < threads.length; ++i) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	382 FJTaskRunner t = threads[i];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	383 int truns = t.runs;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	384 totalRuns += truns;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	385
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	386 int tscans = t.scans;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	387 totalScans += tscans;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	388
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	389 int tsteals = t.steals;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	390 totalSteals += tsteals;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	391
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	392 String star = (getActive(t))? "*" : " ";
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	393
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	394
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	395 System.out.print("T" + i + star +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	396 "\t" + t.deqSize() +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	397 "\t" + tscans +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	398 "\t" + tsteals +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	399 "\t" + truns +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	400 "\n");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	401 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	402
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	403 System.out.print("Total" +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	404 "\t " +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	405 "\t" + totalScans +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	406 "\t" + totalSteals +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	407 "\t" + totalRuns +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	408 "\n");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	409
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	410 System.out.print("Execute: " + entries);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	411
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	412 System.out.print("\tTime: " + secs);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	413
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	414 long rps = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	415 if (secs != 0) rps = Math.round((double)(totalRuns) / secs);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	416
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	417 System.out.println("\tRate: " + rps);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	418 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	419
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	420
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	421 /* ------------ Methods called only by FJTaskRunners ------------- */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	422
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	423
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	424 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	425 * Return the array of threads in this group.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	426 * Called only by FJTaskRunner.scan().
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	427 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	428
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	429 protected FJTaskRunner[] getArray() { return threads; }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	430
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	431
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	432 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	433 * Return a task from entry queue, or null if empty.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	434 * Called only by FJTaskRunner.scan().
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	435 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	436
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	437 protected FJTask pollEntryQueue() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	438 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	439 FJTask t = (FJTask)(entryQueue.poll(0));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	440 return t;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	441 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	442 catch(InterruptedException ex) { // ignore interrupts
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	443 Thread.currentThread().interrupt();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	444 return null;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	445 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	446 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	447
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	448
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	449 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	450 * Return active status of t.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	451 * Per-thread active status can only be accessed and
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	452 * modified via synchronized method here in the group class.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	453 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	454
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	455 protected synchronized boolean getActive(FJTaskRunner t) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	456 return t.active;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	457 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	458
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	459
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	460 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	461 * Set active status of thread t to true, and notify others
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	462 * that might be waiting for work.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	463 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	464
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	465 protected synchronized void setActive(FJTaskRunner t) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	466 if (!t.active) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	467 t.active = true;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	468 ++activeCount;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	469 if (nstarted < threads.length)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	470 threads[nstarted++].start();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	471 else
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	472 notifyAll();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	473 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	474 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	475
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	476 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	477 * Set active status of thread t to false.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	478 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	479
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	480 protected synchronized void setInactive(FJTaskRunner t) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	481 if (t.active) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	482 t.active = false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	483 --activeCount;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	484 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	485 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	486
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	487 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	488 * The number of times to scan other threads for tasks
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	489 * before transitioning to a mode where scans are
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	490 * interleaved with sleeps (actually timed waits).
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	491 * Upon transition, sleeps are for duration of
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	492 * scans / SCANS_PER_SLEEP milliseconds.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	493 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	494 * This is not treated as a user-tunable parameter because
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	495 * good values do not appear to vary much across JVMs or
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	496 * applications. Its main role is to help avoid some
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	497 * useless spinning and contention during task startup.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	498 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	499 static final long SCANS_PER_SLEEP = 15;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	500
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	501 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	502 * The maximum time (in msecs) to sleep when a thread is idle,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	503 * yet others are not, so may eventually generate work that
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	504 * the current thread can steal. This value reflects the maximum time
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	505 * that a thread may sleep when it possibly should not, because there
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	506 * are other active threads that might generate work. In practice,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	507 * designs in which some threads become stalled because others
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	508 * are running yet not generating tasks are not likely to work
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	509 * well in this framework anyway, so the exact value does not matter
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	510 * too much. However, keeping it in the sub-second range does
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	511 * help smooth out startup and shutdown effects.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	512 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	513
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	514 static final long MAX_SLEEP_TIME = 100;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	515
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	516 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	517 * Set active status of thread t to false, and
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	518 * then wait until: (a) there is a task in the entry
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	519 * queue, or (b) other threads are active, or (c) the current
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	520 * thread is interrupted. Upon return, it
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	521 * is not certain that there will be work available.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	522 * The thread must itself check.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	523 * <p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	524 * The main underlying reason
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	525 * for these mechanics is that threads do not
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	526 * signal each other when they add elements to their queues.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	527 * (This would add to task overhead, reduce locality.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	528 * and increase contention.)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	529 * So we must rely on a tamed form of polling. However, tasks
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	530 * inserted into the entry queue do result in signals, so
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	531 * tasks can wait on these if all of them are otherwise idle.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	532 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	533
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	534 protected synchronized void checkActive(FJTaskRunner t, long scans) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	535
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	536 setInactive(t);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	537
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	538 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	539 // if nothing available, do a hard wait
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	540 if (activeCount == 0 && entryQueue.peek() == null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	541 wait();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	542 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	543 else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	544 // If there is possibly some work,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	545 // sleep for a while before rechecking
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	546
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	547 long msecs = scans / SCANS_PER_SLEEP;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	548 if (msecs > MAX_SLEEP_TIME) msecs = MAX_SLEEP_TIME;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	549 int nsecs = (msecs == 0) ? 1 : 0; // forces shortest possible sleep
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	550 wait(msecs, nsecs);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	551 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	552 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	553 catch (InterruptedException ex) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	554 notify(); // avoid lost notifies on interrupts
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	555 Thread.currentThread().interrupt();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	556 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	557 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	558
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	559 /* ------------ Utility methods ------------- */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	560
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	561 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	562 * Start or wake up any threads waiting for work
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	563 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	564
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	565 protected synchronized void signalNewTask() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	566 if (COLLECT_STATS) ++entries;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	567 if (nstarted < threads.length)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	568 threads[nstarted++].start();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	569 else
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	570 notify();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	571 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	572
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	573 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	574 * Create all FJTaskRunner threads in this group.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	575 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	576
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	577 protected void initializeThreads() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	578 for (int i = 0; i < threads.length; ++i) threads[i] = new FJTaskRunner(this);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	579 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	580
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	581
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	582
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	583
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	584 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	585 * Wrap wait/notify mechanics around a task so that
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	586 * invoke() can wait it out
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	587 **/
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	588 protected static final class InvokableFJTask extends FJTask {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	589 protected final Runnable wrapped;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	590 protected boolean terminated = false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	591
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	592 protected InvokableFJTask(Runnable r) { wrapped = r; }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	593
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	594 public void run() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	595 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	596 if (wrapped instanceof FJTask)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	597 FJTask.invoke((FJTask)(wrapped));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	598 else
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	599 wrapped.run();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	600 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	601 finally {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	602 setTerminated();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	603 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	604 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	605
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	606 protected synchronized void setTerminated() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	607 terminated = true;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	608 notifyAll();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	609 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	610
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	611 protected synchronized void awaitTermination() throws InterruptedException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	612 while (!terminated) wait();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	613 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	614 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	615
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	616
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	617 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	618

Mercurial > hg > blitz_stable

annotate src/EDU/oswego/cs/dl/util/concurrent/FJTaskRunnerGroup.java @ 27:511648fa4d64 Version 2.1