Java：在多个线程之间共享一个变量

Question

背景:我正在并行运行自动化测试。使用pom.xml中的分叉，多个浏览器在相同数量的线程中启动，即1个浏览器是1个线程。

pom.xml中的下面插件创建了与线程（fork）计数相等数量的并行**IT.class。
所有这些类都同时并行执行。因此，似乎每当我创建易失性变量或原子整数时，每个线程都会创建自己的这些，因此跨多个线程共享变量的概念是不起作用的。

                <plugin>
                        <artifactId>maven-failsafe-plugin</artifactId>
                        <version>${maven.failsafe.plugin}</version>
                        <configuration>
                            <systemPropertyVariables>
                                <webdriver.base.url>${webdriver.base.url}</webdriver.base.url>
                                                                </systemPropertyVariables>
                            <argLine>
                                -javaagent:${settings.localRepository}/org/aspectj/aspectjweaver/${aspectj.version}/aspectjweaver-${aspectj.version}.jar
                            </argLine>
                            <forkCount>5</forkCount>
                            <reuseForks>true</reuseForks>
                            <includes>
                                <include>**/Parallel*IT.class</include>
                            </includes>
                            <perCoreThreadCount>true</perCoreThreadCount>
                            <properties>
                                <property>
                                    <name>listener</name>
            <value>ru.yandex.qatools.allure.junit.AllureRunListener</value>
                                </property>
                            </properties>
                        </configuration>
                        <executions>
                            <execution>
                                <goals>
                                    <goal>integration-test</goal>
                                    <goal>verify</goal>
                                </goals>
                            </execution>
                        </executions>
                    </plugin>

我只想让一个线程访问“准备测试数据”函数，并将＜code＞标志

我正在按照教程https://www.youtube.com/watch?v=WH5UvQJizH0使用易失性变量实现同步。也许我犯了一些错误，但所有线程都在打印System.out.println（“准备测试数据”）；

尝试 1：易失性和同步

volatile boolean flag = false;

    public synchronized void setFlagTofalse(){
        System.out.println("Inside sync block");
          this.flag = true;
    }
    // works before class only once
    private EventHandler<TestRunStarted> prepareTestData = event -> {
            if(flag==false) {
                System.out.println("Preparing test data");              
                setFlagTofalse();
            }
    };

尝试2：原子和同步

AtomicInteger flag = new AtomicInteger(0);

    private EventHandler<TestRunStarted> prepareTestData = event -> {
        if(flag.get()==0) {
            System.out.println("Preparing test data");
            value.incrementAndGet();
        }

Answer 1

您同步了错误的方法。你可以试试这样的方法：

volatile boolean flag = false;

public void setFlagTofalse(){
    System.out.println("Inside sync block");
    this.flag = true;
}
// works before class only once
private EventHandler<TestRunStarted> prepareTestData = event -> prepareData();

private synchronized void prepareData() {
    if(!flag) {
        System.out.println("Preparing test data");
        setFlagTofalse();
    }
    //prepare data here
}

Answer 2

如果你做了一个测试（flag.get（）==0）和一个操作，你有两个同步这两个东西。只需将你的整个准备测试数据方法标记为同步？

Answer 3

如果我是你，我会在访问标志变量时使用互斥锁。因此，在读取标志的值或更改其值之前，线程必须获取锁。这样，他们就不会同时读取它，或者在旧值被读取时写入新值，等等。

编辑:更多解释

@保罗解释了锁的作用：它基本上是一个球，可以被线抛来抛去。所以，如果你和一群人坐在一个圆圈里，你有了球，该轮到你谈论“X”了。然后，一旦你说完了，你把球放在圆圈的中间，它一直在那里，直到同一个人或其他人再次想要这个球，并拿走它或等到它可用，然后可以谈论“X”。在您的情况下，线程必须具有更改或读取变量标志的锁，因此您要做的是：

Mutex lock = new Mutex();
lock.aquire();
if ( flag == something ){
    //do something
}
mutex.release()

或者如果你正在改变旗帜。

lock.aquire();
flag = something;
lock.release();

如您所见，锁是在线程间共享的。所以它是在管理线程的类中创建的，并被传递给线程中启动的Runnable对象或方法。

所以：

Mutex lock = new Mutex();
Runnable1 r1 = new Runnable1(lock);
Runnable2 r2 = new Runnable2(lock);
//use the lock in the methods of t1 and t2 that use your volitile var
Thread t1 = new Thread(r1);
Thread t2 = new Thread(r2);

t1.start();
t2.start();

//the join wait for completion of the runnable method in your class.
t1.join();
t2.join();

祝你好运：）