migrate to vmlens 2.10

Signed-off-by: christian.lutnik <[email protected]>

Author: chrfwow

pom.xml

@@ -170,7 +170,7 @@
         <dependency>
             <groupId>com.vmlens</groupId>
             <artifactId>api</artifactId>
-            <version>1.2.3</version>
+            <version>1.2.10</version>
         </dependency>
 
     </dependencies>
@@ -307,7 +307,7 @@
             <plugin>
                 <groupId>com.vmlens</groupId>
                 <artifactId>vmlens-maven-plugin</artifactId>
-                <version>1.2.3</version>
+                <version>1.2.10</version>
                 <executions>
                     <execution>
                         <id>test</id>

src/main/java/dev/openfeature/sdk/OpenFeatureClient.java

@@ -7,6 +7,8 @@
 import dev.openfeature.sdk.exceptions.OpenFeatureError;
 import dev.openfeature.sdk.exceptions.ProviderNotReadyError;
 import dev.openfeature.sdk.internal.ObjectUtils;
+import dev.openfeature.sdk.providers.memory.Flag;
+import dev.openfeature.sdk.providers.memory.InMemoryProvider;
 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -16,6 +18,7 @@
 import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Consumer;
 import lombok.Getter;

src/main/java/dev/openfeature/sdk/VmLensTest.java

@@ -1,6 +1,7 @@
 package dev.openfeature.sdk;
 
 import com.vmlens.api.AllInterleavings;
+import com.vmlens.api.Runner;
 import dev.openfeature.sdk.providers.memory.Flag;
 import dev.openfeature.sdk.providers.memory.InMemoryProvider;
 import java.util.HashMap;
@@ -10,14 +11,11 @@
  * Javadoc.
  */
 public class VmLensTest {
-    int jaVar = 0;
-
-
     public static void main(String[] args) throws InterruptedException {
         new VmLensTest().asomeMethod();
     }
 
-    private void asomeMethod() throws InterruptedException {
+    public void asomeMethod() throws InterruptedException {
         var c = new AtomicInteger();
         final OpenFeatureAPI api = new OpenFeatureAPI();
 
@@ -27,36 +25,20 @@ private void asomeMethod() throws InterruptedException {
         flags.put("c", Flag.builder().variant("a", "dfs").defaultVariant("a").build());
         flags.put("d", Flag.builder().variant("a", "asddd").defaultVariant("a").build());
         api.setProviderAndWait(new InMemoryProvider(flags));
+        var client = api.getClient();
         try (AllInterleavings allInterleavings = new AllInterleavings("Concurrent evaluations and hook additions")) {
             while (allInterleavings.hasNext()) {
                 c.incrementAndGet();
-                var client = api.getClient();
-                var firstReady = new Awaitable();
-                Thread first = new Thread("test thread") {
-                    @Override
-                    public void run() {
-                        firstReady.wakeup();
-                        client.getStringValue("a", "a");
-                        //client.getStringValue("a", "a");
-                    }
-                };
-
-                first.start();
-                firstReady.await();
 
-                client.addHooks(new Hook() {});
-                //client.addHooks(new Hook() {});
-
-                first.join();
+                Runner.runParallel(
+                        () -> client.getStringValue("a", "a"),
+                        () -> client.addHooks(new Hook() {})
+                );
             }
         }
 
         api.shutdown();
 
         System.out.println("c = " + c);
-        System.out.println("jaVar = " + jaVar);
-
-        //Thread.sleep(5000);
-        //System.exit(0);
     }
 }