Package com.apple.foundationdb.record.lucene

Class LuceneConcurrency

java.lang.Object

com.apple.foundationdb.record.lucene.LuceneConcurrency

public class LuceneConcurrency
extends Object

Utility class for methods related to synchronizing Futures.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LuceneConcurrency.AsyncToSyncTimeoutException	An exception that is thrown when the async to sync operation times out.

Method Summary

Modifier and Type	Method	Description
static <T> T	asyncToSync(StoreTimer.Wait event, CompletableFuture<T> async, FDBRecordContext recordContext)	An implementation of asyncToSync that is isolated from external exception injections.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

asyncToSync

@Nullable
@API(INTERNAL)
public static <T> T asyncToSync(@Nonnull
 StoreTimer.Wait event,
 @Nonnull
 CompletableFuture<T> async,
 @Nonnull
 FDBRecordContext recordContext)

An implementation of asyncToSync that is isolated from external exception injections. This implementation does NOT perform exception mapping (as the original FDBRecordContext.asyncToSync(com.apple.foundationdb.record.provider.common.StoreTimer.Wait, java.util.concurrent.CompletableFuture<T>) does). This method is meant to be used internally in places where obtaining and using the result of asynchronous operation is required. This method uses the FDBDatabase.getAsyncToSyncTimeout(com.apple.foundationdb.record.provider.common.StoreTimer.Wait) to find the period to use for the timeout. This method will throw the runtime exception that was thrown by the Future's realization in case such error occurred. This method will use the legacy FDBRecordContext.asyncToSync(com.apple.foundationdb.record.provider.common.StoreTimer.Wait, java.util.concurrent.CompletableFuture<T>) if the LUCENE_USE_LEGACY_ASYNC_TO_SYNC property is set to TRUE (the default)

Parameters:

event - the timer event to use for recording the waits

async - the future to wait on

recordContext - the context to use for callback, recording the event and getting the timeout

Returns:

the result of the future's operation