/**
 * Represents the common configuration of a worker.  Used when submitting an item of work
 * to the {@link WorkerExecutor}.
 *
 * @since 5.6
 */
@HasInternalProtocol
public interface WorkerSpec {

    @TaskAction
    public void createHashes() {
        // <1>
        WorkQueue workQueue = getWorkerExecutor().processIsolation(workerSpec -> {
            workerSpec.getClasspath().from(getCodecClasspath());
            workerSpec.forkOptions(options -> {
                options.setMaxHeapSize("64m"); // <2>
            });
        });

        for (File sourceFile : getSource().getFiles()) {

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.workers.internal;

import org.gradle.workers.WorkerSpec;

public class DefaultWorkerSpec implements WorkerSpec {

    @TaskAction
    public void createHashes() {
        // <1>
        WorkQueue workQueue = getWorkerExecutor().processIsolation(workerSpec -> {
            workerSpec.getClasspath().from(getCodecClasspath());
            workerSpec.forkOptions(options -> {
                options.setMaxHeapSize("64m"); // <2>
            });
        });

        for (File sourceFile : getSource().getFiles()) {

    }
    private <T extends WorkParameters> AsyncWorkCompletion submitWork(Class<? extends WorkAction<T>> workActionClass, Action<? super T> parameterAction, WorkerSpec workerSpec, WorkerFactory workerFactory) {
        Class<T> parameterType = isolationScheme.parameterTypeFor(workActionClass);
        T parameters = (parameterType == null) ? null : instantiator.newInstance(parameterType);

    @Inject
    abstract public WorkerExecutor getWorkerExecutor();

    @TaskAction
    public void createHashes() {
        WorkQueue workQueue = getWorkerExecutor().classLoaderIsolation(workerSpec -> {
            workerSpec.getClasspath().from(getCodecClasspath()); // <2>
        });

        for (File sourceFile : getSource().getFiles()) {

    @Inject
    abstract public WorkerExecutor getWorkerExecutor();

    @TaskAction
    public void createHashes() {
        WorkQueue workQueue = getWorkerExecutor().classLoaderIsolation(workerSpec -> {
            workerSpec.getClasspath().from(getCodecClasspath()); // <2>
        });

        for (File sourceFile : getSource().getFiles()) {

import org.gradle.api.file.ConfigurableFileCollection;

/**
 * A worker spec providing the requirements of an isolated classpath.
 *
 * @since 5.6
 */
public interface ClassLoaderWorkerSpec extends WorkerSpec {
    /**
     * Gets the classpath associated with the worker.
     *
     * @return the classpath associated with the worker
     */
    ConfigurableFileCollection getClasspath();

import org.gradle.api.Action;
import org.gradle.process.JavaForkOptions;

/**
 * A worker spec providing the requirements of a forked process.
 *
 * @since 5.6
 */
public interface ForkingWorkerSpec extends WorkerSpec {
    /**
     * Executes the provided action against the {@link JavaForkOptions} object associated with this builder.
     *
     * @param forkOptionsAction - An action to configure the {@link JavaForkOptions} for this builder

import org.gradle.util.UsesNativeServices
import org.gradle.util.internal.RedirectStdOutAndErr
import org.gradle.workers.WorkAction
import org.gradle.workers.WorkParameters
import org.gradle.workers.WorkerSpec
import org.junit.Rule
import spock.lang.Specification

@UsesNativeServices
class DefaultWorkerExecutorTest extends Specification {
    @Rule
    RedirectStdOutAndErr output = new RedirectStdOutAndErr()
    @Rule