)
class NativeParallelPerformanceTest extends AbstractCrossBuildPerformanceTest {

    def "clean assemble with parallel workers"() {
        given:
        runner.testGroup = 'parallel builds'
        runner.buildSpec {
            displayName("parallel")
            invocation {
                tasksToRun("clean", "assemble")
            }
        }
        runner.baseline {

                         first_underlying_devices, status.get());
  ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());

  // Create a second parallel device with the first parallel device and one
  // additional CPU.
  const char* second_device_name =
      "/job:localhost/replica:0/task:0/device:CUSTOM:1";
  std::array<const char*, 2> second_underlying_devices{

func (tg *testgoData) check(err error) {
	tg.t.Helper()
	if err != nil {
		tg.t.Error(err)
	}
}

// parallel runs the test in parallel by calling t.Parallel.
func (tg *testgoData) parallel() {
	tg.t.Helper()
	if tg.ran {
		tg.t.Fatal("internal testsuite error: call to parallel after run")
	}
	for _, e := range tg.env {

	case "plan9":
		t.Skipf("not supported on %s", runtime.GOOS)
	}
	t.Parallel()

	for _, network := range []string{"tcp", "unix", "unixpacket"} {
		network := network
		t.Run(network, func(t *testing.T) {
			if !testableNetwork(network) {
				t.Skipf("network %s is not testable on the current platform", network)
			}
			t.Parallel()

			ln := newLocalListener(t, network)
			switch network {

        when:
        succeeds(":resolve", "--parallel")

        then:
        outputContains("processing producer.jar using []")
        outputContains("processing consumer.jar using [producer.jar]")

        when:
        succeeds(":resolve", "--parallel")

        then:
        outputDoesNotContain("processing")

        when:
        succeeds(":resolve", "--parallel", "-DproducerContent=changed")

        then:

        Set<Long> ids = new CopyOnWriteArraySet<Long>()

        5.times {
            parallel.start {
                100.times {
                    assertTrue(ids.add(generator.generateId()))
                }
            }
        }
        parallel.waitForAll()
    }

<% if (binding.hasVariable("daemonMemory")) { %>org.gradle.jvmargs=-Xms${binding.getVariable("daemonMemory")} -Xmx${binding.getVariable("daemonMemory")}<% } %>
<% if (binding.hasVariable("parallel")) { %>org.gradle.parallel=true<% } %>
<% if (binding.hasVariable("maxWorkers")) { %>org.gradle.workers.max=${binding.getVariable("maxWorkers")}<% } %>
compilerMemory=<% if (binding.hasVariable("compilerMemory")) { %>${binding.getVariable("compilerMemory")}<% } else { %>1g<% } %>

            }
        """

        when:
        args "--parallel"
        execute(buildA, "clean", "build")

        then:
        result.assertTaskOrder(':buildB:clean', ':buildB:compileJava', ':clean', ':compileJava')

        when:
        args "--parallel"
        execute(buildA, "build", "clean")

        then:

package work

import (
	"bytes"
	"cmd/internal/objabi"
	"cmd/internal/sys"
	"fmt"
	"math/rand"
	"testing"
	"time"
	"unicode/utf8"
)

func TestEncodeArgs(t *testing.T) {
	t.Parallel()
	tests := []struct {
		arg, want string
	}{
		{"", ""},
		{"hello", "hello"},
		{"hello\n", "hello\\n"},
		{"hello\\", "hello\\\\"},
		{"hello\nthere", "hello\\nthere"},
		{"\\\n", "\\\\\\n"},
	}

    final def converter = new ParallelismBuildOptions().commandLineConverter()

    def "converts parallel executor"() {
        when:
        def result = convert("--parallel")

        then:
        result.parallelProjectExecutionEnabled == true

        when:
        result = convert("--no-parallel")

        then:
        result.parallelProjectExecutionEnabled == false
    }