15

私のアプリでは、プラグインを個別のアプリ ドメインにロードしてから、プラグイン内のコードを非同期で実行する必要があります。Taskマーシャリング可能な型でラップするコードをいくつか書きました。

static class RemoteTask
{
    public static async Task<T> ClientComplete<T>(RemoteTask<T> remoteTask,
                                                  CancellationToken cancellationToken)
    {
        T result;

        using (cancellationToken.Register(remoteTask.Cancel))
        {
            RemoteTaskCompletionSource<T> tcs = new RemoteTaskCompletionSource<T>();
            remoteTask.Complete(tcs);
            result = await tcs.Task;
        }

        await Task.Yield(); // HACK!!

        return result;
    }

    public static RemoteTask<T> ServerStart<T>(Func<CancellationToken, Task<T>> func)
    {
        return new RemoteTask<T>(func);
    }
}

class RemoteTask<T> : MarshalByRefObject
{
    readonly CancellationTokenSource cts = new CancellationTokenSource();
    readonly Task<T> task;

    internal RemoteTask(Func<CancellationToken, Task<T>> starter)
    {
        this.task = starter(cts.Token);
    }

    internal void Complete(RemoteTaskCompletionSource<T> tcs)
    {
        task.ContinueWith(t =>
        {
            if (t.IsFaulted)
            {
                tcs.TrySetException(t.Exception);
            }
            else if (t.IsCanceled)
            {
                tcs.TrySetCancelled();
            }
            else
            {
                tcs.TrySetResult(t.Result);
            }
        }, TaskContinuationOptions.ExecuteSynchronously);
    }

    internal void Cancel()
    {
        cts.Cancel();
    }
}

class RemoteTaskCompletionSource<T> : MarshalByRefObject
{
    readonly TaskCompletionSource<T> tcs = new TaskCompletionSource<T>();

    public bool TrySetResult(T result) { return tcs.TrySetResult(result); }
    public bool TrySetCancelled() { return tcs.TrySetCanceled(); }
    public bool TrySetException(Exception ex) { return tcs.TrySetException(ex); }

    public Task<T> Task
    {
        get
        {
            return tcs.Task;
        }
    }
}

次のように使用されます。

sealed class ControllerAppDomain
{
    PluginAppDomain plugin;

    public Task<int> SomethingAsync()
    {
        return RemoteTask.ClientComplete(plugin.SomethingAsync(), CancellationToken.None);
    }
}

sealed class PluginAppDomain : MarshalByRefObject
{
    public RemoteTask<int> SomethingAsync()
    {
        return RemoteTask.ServerStart(async cts =>
        {
            cts.ThrowIfCancellationRequested();
            return 1;
        });
    }
}

しかし、私は思わぬ障害に遭遇しました。を調べるとClientComplete、Task.Yield()私が挿入したものがあります。この行にコメントClientCompleteすると、二度と戻りません。何か案は？

4

1 に答える 1

2

私の最善の推測は、awaitを含むasync メソッドが原因でこれらの問題に直面していることです。これは、リサイクルされた Threadを割り当てることができるThreadPoolを介して管理されます。

すべてのサーバー側コードに対して ConfigureAwait を呼び出すベスト プラクティスを参照 してください

実際、 await を実行するだけでそれが可能です（別のスレッドに移動します）。非同期メソッドが待機状態になると、メソッドはブロックされますが、スレッドはスレッド プールに戻ります。メソッドを続行する準備が整うと、スレッド プールから任意のスレッドが取得され、メソッドを再開するために使用されます。

コードを合理化し、ベースライン ケースのスレッドを生成して、パフォーマンスが最後になるようにします。

于 2013-05-27T12:27:33.967 に答える