<dependency>
<groupId>com.atlassian.util.concurrent</groupId>
<artifactId>atlassian-util-concurrent</artifactId>
</dependency>
gradle
dependencies {
}
ManagedExecutorService executor = ManagedExecutorServiceFactory.createManagedExecutorService();
executor.execute(() -> {
});
LockService lockService = LockServiceFactory.getLockService();
Lock lock = lockService.getLock("lockName");
lock.lock();
try {
} finally {
lock.unlock();
}
ManagedRunnable task = new InterruptibleManagedRunnable() {
@Override
public void run() throws InterruptedException {
}
};
ManagedExecutorService executor = ManagedExecutorServiceFactory.createManagedExecutorService();
executor.execute(task);
task.interrupt();
ManagedExecutorService executor = ManagedExecutorServiceFactory.createManagedExecutorService();
ListenableFuture<String> future = executor.submit(() -> {
});
ThreadLocal<Integer> threadLocal = ThreadLocalSuppliers.forSupplier(() -> 42).get();
