如何创建异步方法

Question

我在C#app中有简单的方法,它从FTP服务器中挑选文件并解析它并将数据存储在DB中.我希望它是异步的,以便用户在App上执行其他操作,一旦完成解析,他必须得到消息"解析完成".

我知道它可以通过异步方法调用实现,但我不知道该怎么做才能有人帮助我吗？

Answer 1

您需要使用委托及其BeginInvoke包含的方法异步运行另一个方法.在委托运行的方法结束时,您可以通知用户.例如:

class MyClass
{
    private delegate void SomeFunctionDelegate(int param1, bool param2);
    private SomeFunctionDelegate sfd;

    public MyClass()
    {
        sfd = new SomeFunctionDelegate(this.SomeFunction);
    }

    private void SomeFunction(int param1, bool param2)
    {
        // Do stuff

        // Notify user
    }

    public void GetData()
    {
        // Do stuff

        sfd.BeginInvoke(34, true, null, null);
    }
}

请阅读http://msdn.microsoft.com/en-us/library/2e08f6yc.aspx

Answer 2

试试这个方法

public static void RunAsynchronously(Action method, Action callback) {
    ThreadPool.QueueUserWorkItem(_ =>
    {
        try {
            method();
        } 
        catch (ThreadAbortException) { /* dont report on this */ } 
        catch (Exception ex) {
        }
        // note: this will not be called if the thread is aborted
        if (callback!= null) callback();
    });
}

用法:

RunAsynchronously( () => { picks file from FTP server and parses it}, 
       () => { Console.WriteLine("Parsing is done"); } );

Answer 3

每当你做异步的事情时,你就会使用一个单独的线程,一个新线程,或一个从线程池中获取的线程.这意味着您异步执行的任何操作都必须非常小心与其他线程的交互.

一种方法是将异步线程的代码(称为线程"A")及其所有数据放入另一个类(称为类"A").确保线程"A"仅访问"A"类中的数据.如果线程"A"只接触类"A",并且没有其他线程接触类"A"的数据,那么问题就少了一个:

public class MainClass
{
    private sealed class AsyncClass
    {
        private int _counter;
        private readonly int _maxCount;

        public AsyncClass(int maxCount) { _maxCount = maxCount; }

        public void Run()
        {
            while (_counter++ < _maxCount) { Thread.Sleep(1); }
            CompletionTime = DateTime.Now;
        }

        public DateTime CompletionTime { get; private set; }
    }

    private AsyncClass _asyncInstance;
    public void StartAsync()
    {
        var asyncDoneTime = DateTime.MinValue;
        _asyncInstance = new AsyncClass(10);
        Action asyncAction = _asyncInstance.Run;
        asyncAction.BeginInvoke(
            ar =>
                {
                    asyncAction.EndInvoke(ar);
                    asyncDoneTime = _asyncInstance.CompletionTime;
                }, null);
        Console.WriteLine("Async task ended at {0}", asyncDoneTime);
    }
}

请注意,AsyncClass从外部触及的唯一部分是它的公共接口,而其中唯一的部分是数据CompletionTime.请注意,只有在异步任务完成后才会触及此操作.这意味着没有其他任何东西可以干扰任务内部工作,并且它不会干扰任何其他事情.

Answer 4

这里有两个关于 C# 中线程的链接

• C# 中的线程
• .NET 中的多线程：介绍和建议

我开始阅读有关BackgroundWorker 类的内容