7

以下に示すように、サービスを呼び出すメソッドがあります。

スレッドを介してこのメ​​ソッドを実行するにはどうすればよいですか? 

public List<AccessDetails> GetAccessListOfMirror(string mirrorId,string server)
{
    List<AccessDetails> accessOfMirror = new List<AccessDetails>();
    string loginUserId = SessionManager.Session.Current.LoggedInUserName;
    string userPassword = SessionManager.Session.Current.Password;

    using (Service1Client client = new Service1Client())
    {
        client.Open();
        accessOfMirror = client.GetMirrorList1(mirrorId, server, null);
    }

    return accessOfMirror;
}
4

3 に答える 3

0

以下は私が使用するヘルパー クラスで、RX.NETを参照しています。

それをプロジェクトに含めると、非常に簡単にスレッド化できます。上記のコードは、次のように別のスレッドにスピンオフできます。

int mirrorId = 0;
string server = "xxx";
ASync.Run<List<AccessDetails>>(GetAccessListOfMirror(mirrorId,server), resultList => {
   foreach(var accessDetail in resultList)
   {
         // do stuff with result
   }
}, error => { // if error occured on other thread, handle exception here  });

注目に値する:ラムダ式は元の呼び出しスレッドにマージされます。これは、たとえば GUI スレッドから非同期操作を開始する場合に非常に便利です。

また、別の非常に便利な方法もあります。Fork を使用すると、複数のワーカー スレッドをスピンオフし、すべてのサブスレッドが完了するかエラーになるまで、呼び出し元のスレッドをブロックできます。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Concurrency;

namespace MyProject
{

    public static class ASync
    {
        public static void ThrowAway(Action todo)
        {
            ThrowAway(todo, null);
        }

        public static void ThrowAway(Action todo, Action<Exception> onException)
        {
            if (todo == null)
                return;

            Run<bool>(() =>
            {
                todo();
                return true;
            }, null, onException);
        }

        public static bool Fork(Action<Exception> onError, params Action[] toDo)
        {
            bool errors = false;
            var fork = Observable.ForkJoin(toDo.Select(t => Observable.Start(t).Materialize()));
            foreach (var x in fork.First())
                if (x.Kind == NotificationKind.OnError)
                {
                    if(onError != null)
                        onError(x.Exception);

                    errors = true;
                }

            return !errors;
        }

        public static bool Fork<T>(Action<Exception> onError, IEnumerable<T> args, Action<T> perArg)
        {
            bool errors = false;
            var fork = Observable.ForkJoin(args.Select(arg => Observable.Start(() => { perArg(arg); }).Materialize()));
            foreach (var x in fork.First())
                if (x.Kind == NotificationKind.OnError)
                {
                    if (onError != null)
                        onError(x.Exception);

                    errors = true;
                }

            return !errors;
        }


        public static void Run<TResult>(Func<TResult> todo, Action<TResult> continuation, Action<Exception> onException)
        {
            bool errored = false;
            IDisposable subscription = null;

            var toCall = Observable.ToAsync<TResult>(todo);
            var observable =
                Observable.CreateWithDisposable<TResult>(o => toCall().Subscribe(o)).ObserveOn(Scheduler.Dispatcher).Catch(
                (Exception err) =>
                {
                    errored = true;

                        if (onException != null)
                            onException(err);


                        return Observable.Never<TResult>();
                }).Finally(
                () =>
                {
                    if (subscription != null)
                        subscription.Dispose();
                });

            subscription = observable.Subscribe((TResult result) =>
            {
                if (!errored && continuation != null)
                {
                    try
                    {
                        continuation(result);
                    }
                    catch (Exception e)
                    {
                        if (onException != null)
                            onException(e);
                    }
                }
            });
        }
    }
}
于 2013-05-01T13:48:14.467 に答える