import io.karector.collections.ConcurrentHashSet;
...
ConcurrentHashSet<String> set = new ConcurrentHashSet<>();
set.add("item1");
set.add("item2");
set.add("item3");
set.remove("item2");
import io.karector.util.ThreadPoolExecutorFactory;
...
ThreadPoolExecutor executor = ThreadPoolExecutorFactory.createThreadPoolExecutor();
for (int i = 0; i < 10; i++) {
executor.execute(() -> {
});
}
executor.shutdown();
