Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1224)

Unified Diff: sync/test/android/javatests/src/org/chromium/sync/test/util/SimpleFuture.java

Issue 2130453004: [Sync] Move //sync to //components/sync. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebase. Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: sync/test/android/javatests/src/org/chromium/sync/test/util/SimpleFuture.java
diff --git a/sync/test/android/javatests/src/org/chromium/sync/test/util/SimpleFuture.java b/sync/test/android/javatests/src/org/chromium/sync/test/util/SimpleFuture.java
deleted file mode 100644
index 1cee25ba4ee068cbcea6f2317de61d0330ed6899..0000000000000000000000000000000000000000
--- a/sync/test/android/javatests/src/org/chromium/sync/test/util/SimpleFuture.java
+++ /dev/null
@@ -1,80 +0,0 @@
-// Copyright 2015 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-package org.chromium.sync.test.util;
-
-import org.chromium.base.Callback;
-
-/**
- * A simple tool to make waiting for the result of an asynchronous operation easy.
- *
- * This class is thread-safe; the result can be provided and retrieved on any thread.
- *
- * Example usage:
- *
- * final SimpleFuture<Integer> future = new SimpleFuture<Integer>();
- * getValueAsynchronously(new Callback<Integer>() {
- * public void onResult(Integer result) {
- * // Do some other work...
- * future.provide(result);
- * }
- * }
- * int value = future.get();
- *
- * Or, if your callback doesn't need to do anything but provide the value:
- *
- * SimpleFuture<Integer> result = new SimpleFuture<Integer>();
- * getValueAsynchronously(result.createCallback());
- * int value = result.get();
- *
- * @param <V> The type of the value this future will return.
- */
-public class SimpleFuture<V> {
- private static final int GET_TIMEOUT_MS = 10000;
-
- private final Object mLock = new Object();
- private boolean mHasResult = false;
- private V mResult;
-
- /**
- * Provide the result value of this future for get() to return.
- *
- * Any calls after the first are ignored.
- */
- public void provide(V result) {
- synchronized (mLock) {
- if (mHasResult) {
- // You can only provide a result once.
- return;
- }
- mHasResult = true;
- mResult = result;
- mLock.notifyAll();
- }
- }
-
- /**
- * Get the value of this future, or block until it's available.
- */
- public V get() throws InterruptedException {
- synchronized (mLock) {
- while (!mHasResult) {
- mLock.wait(GET_TIMEOUT_MS);
- }
- return mResult;
- }
- }
-
- /**
- * Helper function to create a {@link Callback} that will provide its result.
- */
- public Callback<V> createCallback() {
- return new Callback<V>() {
- @Override
- public void onResult(V result) {
- provide(result);
- }
- };
- }
-}

Powered by Google App Engine
This is Rietveld 408576698