From 3fc51075792cfc85c1bca478d18eb2cc1cd497af Mon Sep 17 00:00:00 2001
From: Grzegorz Piwowarek <gpiwowarek@gmail.com>
Date: Mon, 5 Aug 2024 10:38:11 +0200
Subject: [PATCH] ConcurrentHashMap#computeIfAbsent

---
 .../README.MD                                 |  0
 java-concurrent-hm-compute-if-absent/pom.xml  | 22 ++++++++++++
 .../pivovarit/chm/ComputeIfAbsentExample.java | 35 +++++++++++++++++++
 pom.xml                                       |  1 +
 4 files changed, 58 insertions(+)
 create mode 100644 java-concurrent-hm-compute-if-absent/README.MD
 create mode 100644 java-concurrent-hm-compute-if-absent/pom.xml
 create mode 100644 java-concurrent-hm-compute-if-absent/src/main/java/com/pivovarit/chm/ComputeIfAbsentExample.java

diff --git a/java-concurrent-hm-compute-if-absent/README.MD b/java-concurrent-hm-compute-if-absent/README.MD
new file mode 100644
index 00000000..e69de29b
diff --git a/java-concurrent-hm-compute-if-absent/pom.xml b/java-concurrent-hm-compute-if-absent/pom.xml
new file mode 100644
index 00000000..18d1b01b
--- /dev/null
+++ b/java-concurrent-hm-compute-if-absent/pom.xml
@@ -0,0 +1,22 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.pivovarit</groupId>
+    <version>1.0</version>
+    <artifactId>java-concurrent-hm-compute-if-absent</artifactId>
+
+    <name>java-concurrent-hm-compute-if-absent</name>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>21</source>
+                    <target>21</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>
diff --git a/java-concurrent-hm-compute-if-absent/src/main/java/com/pivovarit/chm/ComputeIfAbsentExample.java b/java-concurrent-hm-compute-if-absent/src/main/java/com/pivovarit/chm/ComputeIfAbsentExample.java
new file mode 100644
index 00000000..85ea3aae
--- /dev/null
+++ b/java-concurrent-hm-compute-if-absent/src/main/java/com/pivovarit/chm/ComputeIfAbsentExample.java
@@ -0,0 +1,35 @@
+package com.pivovarit.chm;
+
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ThreadLocalRandom;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.stream.Stream;
+
+class ComputeIfAbsentExample {
+
+    public static void main(String[] args) {
+        var map = new ConcurrentHashMap<>(1024);
+        var counter = new AtomicInteger();
+        Stream.of(1, 2)
+          .map(tid -> Thread.ofPlatform().start(() -> {
+              for (int i = 0; i < 10; i++) {
+                  int key = ThreadLocalRandom.current().nextInt(10);
+                  map.computeIfAbsent(key, s -> {
+                      if (counter.incrementAndGet() > 1) {
+                          System.out.println("I told you so!");
+                      }
+                      doWork();
+                      counter.decrementAndGet();
+                      return key;
+                  });
+              }
+          })).forEach(t -> {});
+    }
+
+    private static void doWork() {
+        try {
+            Thread.sleep(100);
+        } catch (InterruptedException ignored) {
+        }
+    }
+}
diff --git a/pom.xml b/pom.xml
index 6a1d53d9..1988de2f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -24,6 +24,7 @@
         <module>java-archunit</module>
         <module>java-sealed-classes</module>
         <module>java-completable-future-timeouts</module>
+        <module>java-concurrent-hm-compute-if-absent</module>
         <module>java-event-sourcing</module>
         <module>java-completable-future-allof</module>
         <module>java-advanced-groupingby</module>