Cách tạo phương thức không đồng bộ

Question

Tôi có phương pháp đơn giản trong ứng dụng C#, nó chọn tệp từ máy chủ FTP và phân tích cú pháp và lưu trữ dữ liệu trong DB. Tôi muốn nó không đồng bộ, để người dùng thực hiện các hoạt động khác trên ứng dụng, khi phân tích cú pháp được thực hiện, anh ta phải nhận được thông báo cho biết "Phân tích cú pháp được thực hiện".

Tôi biết nó có thể đạt được thông qua cuộc gọi phương thức không đồng bộ nhưng Tôi không biết làm thế nào để làm điều đó ai có thể giúp tôi xin vui lòng ??

Answer 1

Dưới đây là hai liên kết về luồng trong C#

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

Tôi muốn bắt đầu đọc về BackgroundWorker class

Answer 2

Bạn cần phải sử dụng các đại biểu và các BeginInvoke phương pháp mà chúng chứa để chạy một phương thức khác không đồng bộ. Một kết thúc của phương thức được điều hành bởi đại biểu, bạn có thể thông báo cho người dùng. Ví dụ:

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

đọc tại http://msdn.microsoft.com/en-us/library/2e08f6yc.aspx

Answer 3

ThreadPool.QueueUserWorkItem là cách nhanh nhất để có được một quá trình đang chạy trên một chủ đề khác nhau.

Hãy lưu ý rằng các đối tượng giao diện người dùng có "ái lực chuỗi" và không thể truy cập được từ bất kỳ chuỗi nào khác ngoài chủ đề đã tạo chúng.

Vì vậy, ngoài việc kiểm tra ThreadPool (hoặc sử dụng mô hình lập trình không đồng bộ thông qua các đại biểu), bạn cần kiểm tra Dispatchers (wpf) hoặc InvokeRequired (winforms).

Answer 4

Bất cứ khi nào bạn đang làm điều gì đó không đồng bộ, bạn đang sử dụng một chuỗi riêng biệt, một chuỗi mới hoặc một chuỗi được lấy từ nhóm chủ đề. Điều này có nghĩa rằng bất cứ điều gì bạn làm không đồng bộ phải rất cẩn thận về tương tác với các chủ đề khác.

Một cách để làm điều đó là đặt mã cho chuỗi không đồng bộ (gọi là chuỗi "A") cùng với tất cả dữ liệu của nó vào một lớp khác (gọi là lớp "A"). Đảm bảo rằng chuỗi "A" chỉ truy cập dữ liệu trong lớp "A". Nếu chủ đề "A" chỉ chạm vào lớp "A", và không có thread khác chạm vào lớp "A" của dữ liệu, sau đó có một ít vấn đề:

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

Chú ý rằng phần duy nhất của AsyncClass đó là chạm từ bên ngoài là giao diện công cộng của nó và phần duy nhất của dữ liệu là CompletionTime. Lưu ý rằng đây là chỉ được chạm sau khi tác vụ không đồng bộ hoàn tất. Điều này có nghĩa rằng không có gì khác có thể can thiệp vào các nhiệm vụ bên trong hoạt động, và nó không thể can thiệp với bất cứ điều gì khác.

Answer 5

Cuối cùng, bạn sẽ phải sử dụng một số loại luồng. Cách nó hoạt động cơ bản là bạn bắt đầu một hàm với một luồng mới và nó sẽ chạy cho đến khi kết thúc hàm.

Nếu bạn đang sử dụng Biểu mẫu Windows thì một trình bao bọc đẹp mà họ có cho điều này gọi là Công nhân nền. Nó cho phép bạn làm việc trong nền với việc khóa lên biểu mẫu giao diện người dùng và thậm chí cung cấp một cách để giao tiếp với các biểu mẫu và cung cấp các sự kiện cập nhật tiến trình.

Background Worker

Answer 6

Trong Asp.Net tôi sử dụng rất nhiều phương pháp tĩnh cho công việc phải làm. Nếu nó chỉ đơn giản là một công việc mà tôi cần không có phản ứng hoặc trạng thái, tôi làm một cái gì đó đơn giản như dưới đây. Như bạn có thể thấy, tôi có thể chọn gọi ResizeImages hoặc ResizeImagesAsync tùy thuộc vào việc tôi muốn đợi nó hoàn thành hay không

Giải thích mã: Tôi sử dụng http://imageresizing.net/ để đổi kích thước/cắt hình ảnh và phương pháp SaveBlobPng là lưu trữ hình ảnh sang Azure (đám mây) nhưng vì điều đó không liên quan đến bản demo này nên tôi không bao gồm mã đó. Đó là một ví dụ tốt về nhiệm vụ tốn thời gian mặc dù

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

Hoặc sẽ cho luồng, do đó bạn không cần phải bận tâm với đại biểu

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

Answer 7

thử phương pháp này

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

Cách sử dụng:

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