Как создать асинхронный метод

Question

У меня есть простой метод в моем приложении C#, он выбирает файл с FTP-сервера и анализирует его и сохраняет данные в БД. Я хочу, чтобы он был асинхронным, чтобы пользователь выполнял другие операции над приложением, как только разбор выполняется, он должен получить сообщение о том, что «Parsing is done».

Я знаю, что это может быть достигнуто посредством асинхронного вызова метода, но Я не знаю, как это сделать Может кто-нибудь мне помочь?

Answer 1

Вот две ссылки о многопоточности в C#

• Threading in C#
• Multi-threading in .NET: Introduction and suggestions

Я начала читать о BackgroundWorker class

Answer 2

Вы должны использовать делегатов и BeginInvoke метод, который они содержат для запуска другого метода асинхронно. A конец метода, выполняемого делегатом, вы можете уведомить пользователя. Например:

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 3

ThreadPool.QueueUserWorkItem это самый быстрый способ получить процесс, протекающий в другом потоке.

Помните, что объекты UI имеют «сходство потоков» и не могут быть доступны из любого потока, отличного от того, который их создал.

Итак, в дополнение к проверке ThreadPool (или с использованием модели асинхронного программирования через делегатов) вам необходимо проверить Dispatchers (wpf) или InvokeRequired (winforms).

Answer 4

Каждый раз, когда вы делаете что-то асинхронное, вы используете отдельный поток, либо новый поток, либо один из пула потоков. Это означает, что все, что вы делаете асинхронно, должно быть очень осторожным в отношении взаимодействия с другими потоками.

Один из способов сделать это, чтобы поместить код для асинхронного потока (назовите его «A») вместе со всеми его данными в другой класс (назовите его классом «A»). Убедитесь, что поток «A» только обращается к данным в классе «A». Если нить «А» только касается класса «А», и никакой другой поток не касается класса «А» "s данные, то есть один меньше проблем:

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 5

В конце концов вам придется использовать какую-то резьбу. Принцип работы в основном заключается в том, что вы запускаете функцию с новым потоком, и она будет работать до конца функции.

Если вы используете Windows Forms, тогда хорошая обертка, которую они имеют для этого, вызывает фонового работника. Это позволяет вам работать в фоновом режиме без блокировки формы пользовательского интерфейса и даже обеспечивает способ общения с формами и обновления событий обновления.

Background Worker

Answer 6

В Asp.Net я использую много статических методов для работ должно быть сделано. Если это просто работа, где мне нужно нет ответа или статус, я делаю что-то простое, как показано ниже. Как вы можете видеть, что я могу выбрать, чтобы позвонить либо ResizeImages или ResizeImagesAsync в зависимости, если я хочу, чтобы ждать его, чтобы закончить или не

код объяснение: Я использую http://imageresizing.net/ для изменения размера/обрезки изображений и метод SaveBlobPng для хранения изображений для Azure (облако), но поскольку это не имеет значения для этой демонстрации, я не включил этот код. Его хороший пример трудоемких задач, хотя

private delegate void ResizeImagesDelegate(string tempuri, Dictionary<string, string> versions); 
private static void ResizeImagesAsync(string tempuri, Dictionary<string, string> versions) 
{ 
    ResizeImagesDelegate worker = new ResizeImagesDelegate(ResizeImages); 
    worker.BeginInvoke(tempuri, versions, deletetemp, null, null); 
} 
private static void ResizeImages(string tempuri, Dictionary<string, string> versions) 
{ 
    //the job, whatever it might be 
    foreach (var item in versions) 
    { 
     var image = ImageBuilder.Current.Build(tempuri, new ResizeSettings(item.Value)); 
     SaveBlobPng(image, item.Key); 
     image.Dispose(); 
    } 
} 

Или собираюсь для нарезания резьбы, так что вам не придется беспокоиться делегатами

private static void ResizeImagesAsync(string tempuri, Dictionary<string, string> versions) 
{ 
    Thread t = new Thread (() => ResizeImages(tempuri, versions, null, null)); 
    t.Start(); 
} 

Answer 7

попробовать этот метод

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"); });