采用 Callable 的 Xamarin Executor

Question

第一部分

您好，我正在尝试更改以下代码以使用 Callable 而不是 可运行，因为我希望提供给 Executor 的函数返回 数据。

using Android.App;
using Android.OS;
using Android.Widget;
using Java.Util.Concurrent;
using Java.Lang;

namespace ServiceExecutor {
    [Activity(Label = "SomeActivity")]
    public class SomeActivity : Activity {
        TextView tv1;

        Runnable r;            
        static IExecutorService exe = Executors.NewSingleThreadExecutor();        

        protected override void OnCreate(Bundle savedInstanceState) {
            base.OnCreate(savedInstanceState);

            tv1 = FindViewById<TextView>(Resource.Id.textView1);

            for (int i = 0; i < 4; i++) {
                r = new Runnable(() => function(i));
                exe.Submit(r);
            }
        }

        public void function(int i) {
            RunOnUiThread(() => tv1.Text += "function " + i.ToString() + "\r\n");
            Thread.Sleep(2000);
        }    
    }
}

我在 Java 中找到了示例，但是当我尝试在 C# 中复制代码时 缺少主类 Callable 并且只有 ICallable 我不能 实例化。不幸的是，Xamarin 文档也提供了 Java 示例！

如果有人可以提供帮助，我将不胜感激！

第二部分

完整的设计理念是一个服务，它有这个嵌入式执行器来运行 任务顺序。顺序执行至关重要，因为服务 将与蓝牙接口有持续的套接字连接，并且只有 一次可以处理一个蓝牙请求（任务）。最初我想使用 IntentService 但我希望该服务在整个生命周期内都保持活跃 应用程序，否则对于每个蓝牙请求，套接字都必须 重新连接。

对于设计方法的任何建议也将不胜感激！

Answer 1

ICallable 和 IFuture 的 C# 示例仅返回您提供的相同字符串...

实现一个基于ICallable的类：

在Call() 方法中是您实现计算并返回结果的地方，ExecutorService 负责调用此方法并存储结果。

public class BoomerangeCallable<T> : Java.Lang.Object, ICallable
{
    T value;
    public BoomerangeCallable(T value)
    {
        this.value = value;
    }
    public Java.Lang.Object Call()
    {
        return value.ToString();
    }
}

使用示例：

var futures = new Stack<IFuture>();
var executor = Executors.NewSingleThreadExecutor();
for (int i = 0; i < 5; i++)
{
    var br = new BoomerangeCallable<string>("StackOverflow");
    futures.Push(executor.Submit(br));
}
while (futures.Count > 0)
{
    Console.WriteLine(futures.Pop().Get());
}