Merge pull request #14155 from Simonx22/android/remove-completable-future

Android: Remove CompletableFuture

Source/Android/app/src/main/java/org/dolphinemu/dolphinemu/ui/main/MainPresenter.kt

@@ -26,7 +26,6 @@ import org.dolphinemu.dolphinemu.model.GameFileCache
 import org.dolphinemu.dolphinemu.services.GameFileCacheManager
 import org.dolphinemu.dolphinemu.utils.AfterDirectoryInitializationRunner
 import org.dolphinemu.dolphinemu.utils.BooleanSupplier
-import org.dolphinemu.dolphinemu.utils.CompletableFuture
 import org.dolphinemu.dolphinemu.utils.ContentHandler
 import org.dolphinemu.dolphinemu.utils.DirectoryInitialization
 import org.dolphinemu.dolphinemu.utils.FileBrowserHelper
@@ -34,7 +33,8 @@ import org.dolphinemu.dolphinemu.utils.PermissionsHandler
 import org.dolphinemu.dolphinemu.utils.ThreadUtil
 import org.dolphinemu.dolphinemu.utils.WiiUtils
 import java.util.Arrays
-import java.util.concurrent.ExecutionException
+import java.util.concurrent.CountDownLatch
+import java.util.concurrent.atomic.AtomicReference
 
 class MainPresenter(private val mainView: MainView, private val activity: FragmentActivity) {
     private var dirToAdd: String? = null
@@ -104,8 +104,9 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
 
     fun onCreate() {
         // Ask the user to grant write permission if relevant and not already granted
-        if (DirectoryInitialization.isWaitingForWriteAccess(activity))
+        if (DirectoryInitialization.isWaitingForWriteAccess(activity)) {
             PermissionsHandler.requestWritePermission(activity)
+        }
 
         val versionName = BuildConfig.VERSION_NAME
         mainView.setVersionString(versionName)
@@ -118,8 +119,7 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
     }
 
     fun launchFileListActivity() {
-        val intent =
+        val intent = if (DirectoryInitialization.preferOldFolderPicker(activity)) {
-            if (DirectoryInitialization.preferOldFolderPicker(activity)) {
             FileBrowserHelper.createDirectoryPickerIntent(
                 activity,
                 FileBrowserHelper.GAME_EXTENSIONS,
@@ -130,8 +130,7 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
         requestDirectory.launch(intent)
     }
 
-    fun handleOptionSelection(itemId: Int, activity: ComponentActivity): Boolean =
+    fun handleOptionSelection(itemId: Int, activity: ComponentActivity): Boolean = when (itemId) {
-        when (itemId) {
         R.id.menu_settings -> {
             mainView.launchSettingsActivity(MenuTag.SETTINGS)
             true
@@ -226,24 +225,25 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
         val recursive = BooleanSetting.MAIN_RECURSIVE_ISO_PATHS.boolean
         val childNames = ContentHandler.getChildNames(uri, recursive)
         if (Arrays.stream(childNames).noneMatch {
-                FileBrowserHelper.GAME_EXTENSIONS
+                FileBrowserHelper.GAME_EXTENSIONS.contains(
-                    .contains(FileBrowserHelper.getExtension(it, false))
+                    FileBrowserHelper.getExtension(
+                        it, false
+                    )
+                )
             }) {
-            MaterialAlertDialogBuilder(activity)
+            MaterialAlertDialogBuilder(activity).setMessage(
-                .setMessage(
                 activity.getString(
                     R.string.wrong_file_extension_in_directory,
                     FileBrowserHelper.setToSortedDelimitedString(FileBrowserHelper.GAME_EXTENSIONS)
                 )
-                )
+            ).setPositiveButton(android.R.string.ok, null).show()
-                .setPositiveButton(android.R.string.ok, null)
-                .show()
         }
 
         val contentResolver = activity.contentResolver
         val canonicalizedUri = contentResolver.canonicalize(uri)
-        if (canonicalizedUri != null)
+        if (canonicalizedUri != null) {
             uri = canonicalizedUri
+        }
 
         val takeFlags = result.flags and Intent.FLAG_GRANT_READ_URI_PERMISSION
         activity.contentResolver.takePersistableUriPermission(uri, takeFlags)
@@ -253,10 +253,7 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
 
     fun installWAD(path: String?) {
         ThreadUtil.runOnThreadAndShowResult(
-            activity,
+            activity, R.string.import_in_progress, 0, {
-            R.string.import_in_progress,
-            0,
-            {
                 val success = WiiUtils.installWAD(path!!)
                 val message =
                     if (success) R.string.wad_install_success else R.string.wad_install_failure
@@ -265,33 +262,28 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
     }
 
     fun importWiiSave(path: String?) {
-        val canOverwriteFuture = CompletableFuture<Boolean>()
         ThreadUtil.runOnThreadAndShowResult(
-            activity,
+            activity, R.string.import_in_progress, 0, {
-            R.string.import_in_progress,
-            0,
-            {
                 val canOverwrite = BooleanSupplier {
+                    val latch = CountDownLatch(1)
+                    val decision = AtomicReference<Boolean>()
                     activity.runOnUiThread {
-                        MaterialAlertDialogBuilder(activity)
+                        MaterialAlertDialogBuilder(activity).setMessage(R.string.wii_save_exists)
-                            .setMessage(R.string.wii_save_exists)
                             .setCancelable(false)
                             .setPositiveButton(R.string.yes) { _: DialogInterface?, _: Int ->
-                                canOverwriteFuture.complete(true)
+                                decision.set(true)
-                            }
+                                latch.countDown()
-                            .setNegativeButton(R.string.no) { _: DialogInterface?, _: Int ->
+                            }.setNegativeButton(R.string.no) { _: DialogInterface?, _: Int ->
-                                canOverwriteFuture.complete(false)
+                                decision.set(false)
-                            }
+                                latch.countDown()
-                            .show()
+                            }.show()
                     }
                     try {
-                        return@BooleanSupplier canOverwriteFuture.get()
+                        latch.await()
-                    } catch (e: ExecutionException) {
-                        // Shouldn't happen
-                        throw RuntimeException(e)
                     } catch (e: InterruptedException) {
                         throw RuntimeException(e)
                     }
+                    decision.get() ?: false
                 }
 
                 val message: Int = when (WiiUtils.importWiiSave(path!!, canOverwrite)) {
@@ -306,23 +298,18 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
     }
 
     fun importNANDBin(path: String?) {
-        MaterialAlertDialogBuilder(activity)
+        MaterialAlertDialogBuilder(activity).setMessage(R.string.nand_import_warning)
-            .setMessage(R.string.nand_import_warning)
             .setNegativeButton(R.string.no) { dialog: DialogInterface, _: Int -> dialog.dismiss() }
             .setPositiveButton(R.string.yes) { dialog: DialogInterface, _: Int ->
                 dialog.dismiss()
                 ThreadUtil.runOnThreadAndShowResult(
-                    activity,
+                    activity, R.string.import_in_progress, R.string.do_not_close_app, {
-                    R.string.import_in_progress,
-                    R.string.do_not_close_app,
-                    {
                         // ImportNANDBin unfortunately doesn't provide any result value...
                         // It does however show a panic alert if something goes wrong.
                         WiiUtils.importNANDBin(path!!)
                         null
                     })
-            }
+            }.show()
-            .show()
     }
 
     private fun launchOnlineUpdate() {
@@ -332,8 +319,7 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
             launchUpdateProgressBarFragment(activity)
         } else {
             SystemMenuNotInstalledDialogFragment().show(
-                activity.supportFragmentManager,
+                activity.supportFragmentManager, SystemMenuNotInstalledDialogFragment.TAG
-                SystemMenuNotInstalledDialogFragment.TAG
             )
         }
     }
@@ -344,8 +330,7 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
                 EmulationActivity.launchSystemMenu(activity)
             } else {
                 SystemMenuNotInstalledDialogFragment().show(
-                    activity.supportFragmentManager,
+                    activity.supportFragmentManager, SystemMenuNotInstalledDialogFragment.TAG
-                    SystemMenuNotInstalledDialogFragment.TAG
                 )
             }
         }
@@ -372,8 +357,9 @@ class MainPresenter(private val mainView: MainView, private val activity: Fragme
 
         private fun launchUpdateProgressBarFragment(activity: FragmentActivity) {
             val progressBarFragment = SystemUpdateProgressBarDialogFragment()
-            progressBarFragment
+            progressBarFragment.show(
-                .show(activity.supportFragmentManager, SystemUpdateProgressBarDialogFragment.TAG)
+                activity.supportFragmentManager, SystemUpdateProgressBarDialogFragment.TAG
+            )
             progressBarFragment.isCancelable = false
         }
     }

Source/Android/app/src/main/java/org/dolphinemu/dolphinemu/utils/CompletableFuture.java

@@ -1,97 +0,0 @@
-// SPDX-License-Identifier: GPL-2.0-or-later
-
-package org.dolphinemu.dolphinemu.utils;
-
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.Future;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
-import java.util.concurrent.locks.Condition;
-import java.util.concurrent.locks.Lock;
-import java.util.concurrent.locks.ReentrantLock;
-
-/**
- * Simplified re-implementation of a subset of {@link java.util.concurrent.CompletableFuture}.
- * Replace this class with that class once we have full Java 8 support (once we require API 24).
- */
-public class CompletableFuture<T> implements Future<T>
-{
-  private final Lock lock = new ReentrantLock();
-  private final Condition done = lock.newCondition();
-
-  private boolean isDone = false;
-  private T result = null;
-
-  @Override
-  public boolean cancel(boolean mayInterruptIfRunning)
-  {
-    throw new UnsupportedOperationException();
-  }
-
-  @Override
-  public boolean isCancelled()
-  {
-    return false;
-  }
-
-  @Override
-  public boolean isDone()
-  {
-    return isDone;
-  }
-
-  @Override
-  public T get() throws ExecutionException, InterruptedException
-  {
-    lock.lock();
-    try
-    {
-      while (!isDone)
-        done.await();
-
-      return result;
-    }
-    finally
-    {
-      lock.unlock();
-    }
-  }
-
-  @Override
-  public T get(long timeout, TimeUnit unit)
-          throws ExecutionException, InterruptedException, TimeoutException
-  {
-    lock.lock();
-    try
-    {
-      while (!isDone)
-      {
-        if (!done.await(timeout, unit))
-          throw new TimeoutException();
-      }
-
-      return result;
-    }
-    finally
-    {
-      lock.unlock();
-    }
-  }
-
-  public boolean complete(T value)
-  {
-    lock.lock();
-    try
-    {
-      boolean wasDone = isDone;
-      result = value;
-      isDone = true;
-      done.signalAll();
-      return !wasDone;
-    }
-    finally
-    {
-      lock.unlock();
-    }
-  }
-}