Java 类android.support.v4.content.ParallelExecutorCompat 实例源码

@NonNull
public final <T> ListenableFuture<Integer> updateAsync(@NonNull final T sample, @Nullable final Expression where,
                                                       @NonNull final String... projection) {
    final SettableFuture<Integer> future = SettableFuture.create();
    ParallelExecutorCompat.getParallelExecutor().execute(new Runnable() {
        @Override
        public void run() {
            try {
                future.set(update(sample, where, projection));
            } catch (final Throwable t) {
                future.setException(t);
            }
        }
    });
    return future;
}

@NonNull
public final ListenableFuture<?> updateOrInsertAsync(@NonNull final Object obj,
                                                     @NonNull final String... projection) {
    final SettableFuture<Long> future = SettableFuture.create();
    ParallelExecutorCompat.getParallelExecutor().execute(new Runnable() {
        @Override
        public void run() {
            try {
                updateOrInsert(obj, projection);
                future.set(null);
            } catch (final Throwable t) {
                future.setException(t);
            }
        }
    });
    return future;
}

@NonNull
public final <T> ListenableFuture<List<T>> getAsync(@NonNull final Query<T> query) {
    final SettableFuture<List<T>> future = SettableFuture.create();
    ParallelExecutorCompat.getParallelExecutor().execute(new Runnable() {
        @Override
        public void run() {
            try {
                future.set(get(query));
            } catch (final Throwable t) {
                future.setException(t);
            }
        }
    });
    return future;
}

@NonNull
public final ListenableFuture<Cursor> getCursorAsync(@NonNull final Query<?> query) {
    final SettableFuture<Cursor> future = SettableFuture.create();
    ParallelExecutorCompat.getParallelExecutor().execute(new Runnable() {
        @Override
        public void run() {
            try {
                future.set(getCursor(query));
            } catch (final Throwable t) {
                future.setException(t);
            }
        }
    });
    return future;
}

@NonNull
public final <T> ListenableFuture<T> findAsync(@NonNull final Class<T> clazz, @NonNull final Object... key) {
    final SettableFuture<T> future = SettableFuture.create();
    ParallelExecutorCompat.getParallelExecutor().execute(new Runnable() {
        @Override
        public void run() {
            try {
                future.set(find(clazz, key));
            } catch (final Throwable t) {
                future.setException(t);
            }
        }
    });
    return future;
}

@NonNull
public final ListenableFuture<Long> insertAsync(@NonNull final Object obj, final int conflictAlgorithm) {
    final SettableFuture<Long> future = SettableFuture.create();
    ParallelExecutorCompat.getParallelExecutor().execute(new Runnable() {
        @Override
        public void run() {
            try {
                future.set(insert(obj, conflictAlgorithm));
            } catch (final Throwable t) {
                future.setException(t);
            }
        }
    });
    return future;
}

@NonNull
public final ListenableFuture<Integer> updateAsync(@NonNull final Object obj, @NonNull final String... projection) {
    final SettableFuture<Integer> future = SettableFuture.create();
    ParallelExecutorCompat.getParallelExecutor().execute(new Runnable() {
        @Override
        public void run() {
            try {
                future.set(update(obj, projection));
            } catch (final Throwable t) {
                future.setException(t);
            }
        }
    });
    return future;
}