* <p>The worker process executes the request using an instance of the implementation type specified as a parameter to {@link WorkerProcessFactory#multiRequestWorker(Class)}.</p>
 *
 * <p>The worker process must be explicitly started and stopped using the methods on {@link WorkerControl}.</p>
 */
public interface MultiRequestWorkerProcessBuilder<IN, OUT> extends WorkerProcessSettings {
    /**
     * Creates a worker.
     *

func (c *cacheWatcher) stopLocked() {
	if !c.stopped {
		c.stopped = true
		// stop without draining the input channel was requested.
		if !c.drainInputBuffer {
			close(c.done)
		}
		close(c.input)
	}

	// Even if the watcher was already stopped, if it previously was
	// using draining mode and it's not using it now we need to

 *
 * TODO - this type could be simplified, as there is no longer any need to send/receive messages to/from multiple connections
 */
public class MessageHub implements AsyncStoppable {
    private enum State {Running, Stopping, Stopped}

    private static final Discard DISCARD = new Discard();
    private final ManagedExecutor workers;
    private final String displayName;
    private final Action<? super Throwable> errorHandler;

    }

    public ServiceRegistry getServices() {
        return services;
    }

    @Override
    public void close() {
        // Force the user home services to be stopped first, because the dependencies between the user home services and the global services are not preserved currently
        CompositeStoppable.stoppable(services.get(GradleUserHomeScopeServiceRegistry.class), services).stop();
    }

            instant.actionCompleted
        }

        when:
        async {
            worker.runLater(action)
            worker.stop()
            instant.stopped
        }

        then:
        instant.stopped > instant.actionCompleted
    }

    def "can use operation to test that a method blocks until action is complete"() {
        Worker worker = new Worker(executor)

        given:

	{14, "SIGALRM", "alarm clock"},
	{15, "SIGTERM", "terminated"},
	{16, "SIGURG", "urgent I/O condition"},
	{17, "SIGSTOP", "stopped (signal)"},
	{18, "SIGTSTP", "stopped"},
	{19, "SIGCONT", "continued"},
	{20, "SIGCHLD", "child exited"},
	{21, "SIGTTIN", "stopped (tty input)"},
	{22, "SIGTTOU", "stopped (tty output)"},
	{23, "SIGIO", "I/O possible"},
	{24, "SIGXCPU", "cputime limit exceeded"},

	17: "user defined signal 2",
	18: "child exited",
	19: "power failure",
	20: "window changed",
	21: "urgent I/O condition",
	22: "I/O possible",
	23: "stopped (signal)",
	24: "stopped",
	25: "continued",
	26: "stopped (tty input)",
	27: "stopped (tty output)",
	28: "virtual timer expired",
	29: "profiling timer expired",
	30: "CPU time limit exceeded",
	31: "file size limit exceeded",

	17: "user defined signal 2",
	18: "child exited",
	19: "power failure",
	20: "window changed",
	21: "urgent I/O condition",
	22: "I/O possible",
	23: "stopped (signal)",
	24: "stopped",
	25: "continued",
	26: "stopped (tty input)",
	27: "stopped (tty output)",
	28: "virtual timer expired",
	29: "profiling timer expired",
	30: "CPU time limit exceeded",
	31: "file size limit exceeded",

	17: "user defined signal 2",
	18: "child exited",
	19: "power failure",
	20: "window changed",
	21: "urgent I/O condition",
	22: "I/O possible",
	23: "stopped (signal)",
	24: "stopped",
	25: "continued",
	26: "stopped (tty input)",
	27: "stopped (tty output)",
	28: "virtual timer expired",
	29: "profiling timer expired",
	30: "CPU time limit exceeded",
	31: "file size limit exceeded",

	17: "user defined signal 2",
	18: "child exited",
	19: "power failure",
	20: "window changed",
	21: "urgent I/O condition",
	22: "I/O possible",
	23: "stopped (signal)",
	24: "stopped",
	25: "continued",
	26: "stopped (tty input)",
	27: "stopped (tty output)",
	28: "virtual timer expired",
	29: "profiling timer expired",
	30: "CPU time limit exceeded",
	31: "file size limit exceeded",