X zaman süresi ve rapor ilerlemesi için bekleyiniz.

Question

Daha iyi bir tasarıma sahip Task görevinden daha iyi bir tasarıma ihtiyacım var Thread.Sleep, Görev sınıfını kullanıyorum.

Benim wpf uygulamasında bir Görev yürüttüğümde, bu görevin her biri bir kaç görev çalıştırıyor, bu görevlerin her biri önce giriş yapıyorlar ve İnternet web sitesi, giriş yaptıktan sonra birkaç saniye beklemeli ve devam edecekleri zaman kullanıcıyı bilgilendirmelidirler daha fazla ve bu benim sorunum, çünkü Thread.Sleep ile ilerlemeyi bildiremiyorum.

Oturum açmadan daha fazla işlev var, yaklaşık 5-6, hepsi bir Internet kaynağı istiyor ve aralarında geriye kalan zaman raporunun gönderilmesiyle birlikte bir uyku zamanı olması gerekiyor gui, bu 5-6 işlevi Bir Görevde, ancak birçok görev olabilir. i gerekenler

görev beklemesi, aynı zamanda GUI geçmek için kalan zamanında güncellemeleri göndermek için izin vermektir.

Bu sorunla ilgili herhangi bir fikriniz var mı, nasıl daha iyi hale getirilir, belki de böyle bir sorun için tasarım desenleriniz var mı?

Ayrıca Thread.Sleep'ın zayıf bir tasarım uygulaması olduğunu duydum.

DÜZENLEME: kimse bilmiyor? İplik ile beklemede bir tür süreölçerle bekleyiniz waithandle, autoresetevent, anybody?

Answer 1

Thread.Sleep'ı kullanmayı unut. Bunun yerine, görevinizi bir arka plan iş parçacığında çalıştırın ve bir AutoResetEvent ile bir WaitHandle kullanın. (Bağlantılar: WaitHandle/WaitOne/AutoReset)

güncellemelerini gönderebilir Geçmişiniz iplik zaman uyumsuz delegelerle UI, ama her iki şey olur dek çağıran iş parçacığı bunu bekler: o kadar görevini tamamlamış

1) Kişisel iplik raporlarını yourwaithandle.Set() kullanarak

veya ) bekleme iplik zaman aşımı (zaman aşımı değerini WaitOne parametre olarak ayarlanır() kullanılan yöntem).

Answer 2

yerine tek bir görev, bu yarım düzineden fonksiyonları (giriş, vs.) her yerine sahip olmak yerine, her biri ayrı bir görevi işlev yapmak. Daha sonra zamana göre sıralanan bir öncelik sırası oluşturabilirsiniz. Bu meta görevlerden birini başlatmak istediğinizde, ilk işlevini, sıradaki verileri (ör. URL, kullanıcı kimliği, parola vb.) Ile birlikte bir sıraya yerleştirirsiniz.

Her işlev tamamlandığında, gerçekleştirilecek bir sonraki işlevi sıraya alır. İlk iki işlev giriş ve get_data eğer Yani, olurdu:

queue login with state data to execute at DateTime.Now 
When login is finished, it queues get_data with the state data and DateTime.Now + 5 seconds (or whatever time) 

son işlevi yerine getirdiğinde, bu yerde sonuçlarını nakleder.

Daha sonra kuyruğunu saniyede 10 kere anket (ya da bir şey kuyruğuna eklenir her Zamanlayıcı sonraki kene zaman güncellenecektir var) bir zamanlayıcı ayarlayabilirsiniz. Bireysel görevleri gerektiği gibi başlatabilir.

Yeni Async CTP, şu anda bu tür bir şeye sahip olabilir: "zamanında görev yürüt". Bakmaya değer olabilir. başlatıldığında ilerleme rapor gelince

, her fonksiyonu (yani "in günlüğü" "verileri almak için 5 saniye bekledikten ..." ... vb "veri alma") ilerlemeyi bildirebilirsiniz İsterseniz, sizi Zamanlayıcı iş parçacığını öncelik sırasına düzenli olarak yürütebilir ve belirli görevler yürütüldüğünde rapor verebilir. Bu aşırı olmasına rağmen olabilir.

Ve ne duymuş haklı: Thread.Sleep parçacığı havuzu iş parçacığı birlikte çalışıyoruz, özellikle son derece kötü bir fikir.

Answer 3

Çözüm, eşzamanlı bir beklemeden ziyade async geri çağırma olarak ele almaktır. Bu aynı zamanda veri akışı veya Rx için ideal bir kullanım vaka gibi görünüyor

async item => { await Task.Delay(1000); Process(item); }

: Eğer zaman uyumsuz CTP üzerinde ise hiç , doğru yol olacaktır.

kullanma Reaktif Uzantıları:

static void Track(int timeout, int frequency, string item) 
    { 
     Observable.Interval(TimeSpan.FromSeconds(frequency)) //produces 0, 1, 2.. with the interval 
        .Do(i => Console.WriteLine("Working on {0}", item)) // work on item 
        .TakeUntil(Observable.Timer(TimeSpan.FromSeconds(timeout))) //stop once the timer publishes a value 
        .Subscribe 
        (
         i => Console.WriteLine("Reporting {0}%", ((double)(i + 1)/timeout * 100)), // the interval reaches OnNext 
         e => Console.WriteLine("Error!"), // error occured 
         () => Console.WriteLine("Completed") // observable completed 
       ); 
    } 

Track(timeout: 5, frequency: 1, item: "http://example.com/?") ile bu çağırarak günü, üretilen çıktı şöyle olur:

Working on http://example.com/? 
Reporting 20% 
Working on http://example.com/? 
Reporting 40% 
Working on http://example.com/? 
Reporting 60% 
Working on http://example.com/? 
Reporting 80% 
Completed 

Answer 4

sen ara sayfayı gerçekleştirmek için (System.Timers itibaren) bir Timer kullanarak düşündünüz mü " "mesaj güncellemeleri mi kaldı? Görevlerinizin her biri tamamlanma değeri için beklenen bir süreyi ayarlayabilir, ardından zamanlayıcı göreviniz kullanıcı arayüzünü gerektiği gibi saymak ve güncellemek için sorumlu olabilir. Hiçbir Thread.Sleep gerekli ve Timer bir iş parçacığı havuzu iş parçacığı üzerinde Tick kodunu yürütecek.