ordered_message_processor Sınıfı
, ordered_message_processor ileti bloklarının iletileri alındıkları sırayla işlemesine olanak tanıyan bir message_processor öğedir.
Sözdizimi
template<class T>
class ordered_message_processor : public message_processor<T>;
Parametreler
T
İşlemci tarafından işlenen iletilerin yük türü.
Üyeler
Genel Tür Tanımları
| Veri Akışı Adı | Açıklama |
|---|---|
type |
için Tbir tür diğer adı. |
Ortak Oluşturucular
| Veri Akışı Adı | Açıklama |
|---|---|
| ordered_message_processor | Bir ordered_message_processor nesne oluşturur. |
| ~ordered_message_processor Yıkıcı | Nesneyi yok eder ordered_message_processor . |
Genel Yöntemler
| Veri Akışı Adı | Açıklama |
|---|---|
| async_send | Bu işlem henüz yapılmadıysa, iletileri zaman uyumsuz olarak kuyruğa alır ve bir işlem görevi başlatır. (Geçersiz kılmalar message_processor::async_send.) |
| Başlatmak | ordered_message_processor Nesneyi uygun geri çağırma işlevi, zamanlayıcı ve zamanlama grubuyla başlatır. |
| initialize_batched_processing | Toplu ileti işlemeyi başlatma |
| sync_send | Bu işlem henüz yapılmadıysa, iletileri zaman uyumlu bir şekilde kuyruğa alır ve bir işlem görevi başlatır. (Geçersiz kılmalar message_processor::sync_send.) |
| beklemek | Blok yok etmeden önce tüm zaman uyumsuz işleme görevlerinin bitmesini sağlamak için ileti bloklarının yıkıcılarında kullanılan işlemciye özgü döndürme beklemesi. (Geçersiz kılmalar message_processor::wait.) |
Korumalı Yöntemler
| Veri Akışı Adı | Açıklama |
|---|---|
| process_incoming_message | Zaman uyumsuz olarak çağrılan işleme işlevi. İletileri sıralar ve işlemeye başlar. (Geçersiz kılmalar message_processor::p rocess_incoming_message.) |
Devralma Hiyerarşisi
ordered_message_processor
Gereksinimler
Üst bilgi: agents.h
Ad alanı: eşzamanlılık
async_send
Bu işlem henüz yapılmadıysa, iletileri zaman uyumsuz olarak kuyruğa alır ve bir işlem görevi başlatır.
virtual void async_send(_Inout_opt_ message<T>* _Msg);
Parametreler
_Msg
İleti işaretçisi.
Başlatmak
ordered_message_processor Nesneyi uygun geri çağırma işlevi, zamanlayıcı ve zamanlama grubuyla başlatır.
void initialize(
_Inout_opt_ Scheduler* _PScheduler,
_Inout_opt_ ScheduleGroup* _PScheduleGroup,
_Handler_method const& _Handler);
Parametreler
_PScheduler
Basit görevleri zamanlamak için kullanılacak zamanlayıcı işaretçisi.
_PScheduleGroup
Basit görevleri zamanlamak için kullanılacak zamanlama grubuna yönelik bir işaretçi.
_Işleyicisi
geri çağırma sırasında çağırılan işleyici functor.
initialize_batched_processing
Toplu ileti işlemeyi başlatma
virtual void initialize_batched_processing(
_Handler_method const& _Processor,
_Propagator_method const& _Propagator);
Parametreler
_Işlemci
geri çağırma sırasında işlemci functor çağrılır.
_Yayılması
Geri çağırma sırasında çağırılan propagator functor.
ordered_message_processor
Bir ordered_message_processor nesne oluşturur.
ordered_message_processor();
Açıklamalar
Bu ordered_message_processor , işlev çağrılana kadar initialize zaman uyumsuz veya zaman uyumlu işleyicileri zamanlamaz.
~ordered_message_processor
Nesneyi yok eder ordered_message_processor .
virtual ~ordered_message_processor();
Açıklamalar
İşlemciyi yok etmeden önce tüm bekleyen zaman uyumsuz işlemleri bekler.
process_incoming_message
Zaman uyumsuz olarak çağrılan işleme işlevi. İletileri sıralar ve işlemeye başlar.
virtual void process_incoming_message();
sync_send
Bu işlem henüz yapılmadıysa, iletileri zaman uyumlu bir şekilde kuyruğa alır ve bir işlem görevi başlatır.
virtual void sync_send(_Inout_opt_ message<T>* _Msg);
Parametreler
_Msg
İleti işaretçisi.
wait
Blok yok etmeden önce tüm zaman uyumsuz işleme görevlerinin bitmesini sağlamak için ileti bloklarının yıkıcılarında kullanılan işlemciye özgü döndürme beklemesi.
virtual void wait();