C#: Chặn cuộc gọi chức năng cho đến khi điều kiện đáp ứng

Question

Tôi đang phát triển ứng dụng C# Winforms, một phần của ứng dụng sẽ tải tệp lên máy chủ web bằng cách sử dụng AsyncUpload (sử dụng nó, do cần sử dụng gọi lại porgress), Trong C# chương trình

tôi đã nhận một đơn giản cho vòng lặp mà các cuộc gọi chức năng tải lên

for(int i=0;i < 10 ; i++) 
{ 
    Uploadfun(); 
} 

Và những niềm vui hiện một số ma thuật:

Uploadfun() 
    { 
    // Logic comes here 

    // webClient.UploadFileAsync runs a 2nd thread to perform upload .. 
    webClient.UploadFileAsync(uri, "PUT", fileNameOnHD); 

} 

Và một callback mà được gọi là w hen tải lên Async được thực hiện

Upload_Completed_callback() 
{ 
    //Callback event 
} 

Sửa

Logic trình tự:

1. Fun được gọi (từ vòng lặp)
2. Logic Fun được thực hiện và thực hiện ..
3. Quay lại vòng lặp
4. Gọi lại sẽ được gọi là eventuall y, khi UploadFileAsync (đang chạy một số logic trong một chuỗi khác) sẽ kết thúc

Vấn đề nằm ở điểm thứ ba, khi thực hiện di chuyển trở lại vòng lặp, tôi cần chặn vòng lặp tiếp tục cho đến khi gọi lại được gọi.

Answer 1

Vì vậy, nếu tôi hiểu chính xác, bạn muốn gọi UploadFileAsync sau đó chặn cho đến khi cuộc gọi không đồng bộ đã nhấn gọi lại của bạn. Nếu như vậy, tôi muốn sử dụng AutoResetEvent tức

private readonly AutoResetEvent _signal = new AutoResetEvent(false); 

fun() 
    { 
    // Logic comes here 

    // runs a 2nd thread to perform upload .. calling "callback()" when done 
    webClient.UploadFileAsync(uri, "PUT", fileNameOnHD); 

    _signal.WaitOne(); // wait for the async call to complete and hit the callback  
} 



callback() 
{ 
    //Callback event 
    _signal.Set(); // signal that the async upload completed 
} 

Sử dụng AutoResetEvent có nghĩa là nhà nước được tự động thiết lập lại sau khi Set đã được gọi và một tiểu trình đang chờ nhận được tín hiệu thông qua WaitOne

Answer 2

Trong phương pháp C# chặn theo mặc định, vì vậy bạn không cần phải làm gì cả. Tôi giả định rằng đối với một số lý do bạn đang gọi một phương pháp không chặn bắt đầu một nhiệm vụ nền/thread/bất cứ điều gì và cung cấp cho bạn một cuộc gọi lại khi nó được thực hiện. Bạn muốn gọi phương thức asynchonous này theo cách đồng bộ.

Bạn có thể gọi fun từ bên trong cuộc gọi lại. Nội dung nào đó dọc theo các dòng này (mã giả):

int n; 

callFunTenTimes() 
{ 
    n = 0; 
    fun(n); 
} 

callback() 
{ 
    ++n; 
    if (n < 10) 
     fun(n); 
    else 
     print("done"); 
} 

Điều này tương tự như continuation passing style.

Lợi thế của phương pháp này là bạn cũng có thể làm cho phương thức của bạn không đồng bộ mà không cần thêm bất kỳ chuỗi, khóa hoặc logic bổ sung nào - bạn chỉ cần cung cấp chức năng gọi lại mà khách hàng của bạn có thể đăng ký. Nó hoạt động tốt trong một môi trường hướng sự kiện.

Answer 3

Vấn đề là ở đây:

for(int i=0;i < 10 ; i++) 
{ 
    fun(); <-- if we block until this function finishes here, we stop the UI thread 
} 

Việc bạn đang làm là tuần tự.Và nếu bạn không thể đủ khả năng để chặn thread UI, di chuyển vòng ra khỏi thread UI:

volatile downloadComplete; 

void DownloadUpdates() 
{ 
    ThreadPool.QueueUserWorkItem(state => 
     for(int i = 0; i < 10; i++) 
     { 
      downloadComplete = false; 
      webClient.UploadFileAsync(uri, "PUT", fileNameOnHD); 
      while(!downloadComplete) { Thread.Sleep(1); } 
     }); 
} 

Upload_Completed_callback() 
{ 
    downloadComplete = true; 
} 

Bây giờ bạn có thể chặn việc thực hiện các vòng lặp mà không ngăn chặn thread UI của bạn, và bạn cũng nhận được lợi ích của chỉ báo tiến trình từ lớp webclient.

Answer 4

Zebrabox có quyền sử dụng WaitHandle. Trong khi giải pháp của Juliet không hoạt động, chuỗi thực hiện chờ đợi sẽ tiêu thụ một lượng đáng kể bộ vi xử lý tương ứng với WaitHandle, mà về cơ bản sẽ không hoạt động.