Threadsafe datastructures

[hknlof]

Hi Team,

I am thinking about how to best share state across multiple Threads by adhering to the reactive programming model in Quarkus. My imports for web are:

    implementation 'io.quarkus:quarkus-resteasy-reactive'
    implementation 'io.quarkus:quarkus-resteasy-reactive-jackson'

Let's say I have a singleton class, that represents a Pool of functions. In the below example SHARABLE MUST become ThreadSafe. How would I best go about it?

import io.smallrye.mutiny.helpers.queues.Queues;
import java.util.Queue;
import java.util.function.BiFunction;
import javax.inject.Singleton;


@Singleton
public class Pool {
  private static final Queue<BiFunction<String, String, String>> SHARABLE = Queues.createStrictSizeQueue(10);
  
  private static final BiFunction<String, String, String> HELLO_WORLD = 
      (personName, worldName) -> String.format("Hello %s in world %s", personName, worldName);
  
  BiFunction<String, String, String> retrieveNext() {
    return SHARABLE.poll();
  } 
}