Kelas message_processor

Kelas message_processor adalah kelas dasar abstrak untuk pemrosesan message objek. Tidak ada jaminan pada urutan pesan.

Sintaks

template<class T>
class message_processor;

Parameter

T
Jenis data payload dalam pesan yang ditangani oleh objek ini message_processor .

Anggota

Typedef Publik

Nama	Deskripsi
type	Alias jenis untuk T.

Metode Publik

Nama	Deskripsi
async_send	Ketika ditimpa di kelas turunan, memasukkan pesan ke dalam blok secara asinkron.
sync_send	Ketika didefinisikan ulang di kelas turunan, menempatkan pesan ke dalam blok secara sinkron.
Tunggu	Ketika dioverride di kelas turunan, menunggu hingga semua operasi asinkron selesai.

Metode yang Dilindungi

Nama	Deskripsi
process_incoming_message	Ketika diimplementasikan ulang dalam kelas turunan, melakukan pemrosesan awal pesan ke dalam blok. Dipanggil sekali setiap kali pesan baru ditambahkan dan antrean ditemukan kosong.

Hierarki Pewarisan

message_processor

Persyaratan

Header: agents.h

Namespace: konkurensi

async_send

Ketika di-override dalam kelas turunan, menempatkan pesan ke dalam blok secara asinkron.

virtual void async_send(_Inout_opt_ message<T>* _Msg) = 0;

Parameter

_Msg
Objek message untuk dikirim secara asinkron.

Keterangan

Implementasi prosesor harus mengambil alih metode ini.

proses_pesan_masuk

Saat ditimpa dalam kelas turunan, fungsi ini melaksanakan pemrosesan maju dari pesan menjadi blok. Dipanggil sekali setiap kali pesan baru ditambahkan dan antrean ditemukan kosong.

virtual void process_incoming_message() = 0;

Keterangan

Implementasi blok pesan harus mengambil alih metode ini.

sync_send

Ketika di-override dalam kelas turunan ini, menempatkan pesan ke blok secara sinkron.

virtual void sync_send(_Inout_opt_ message<T>* _Msg) = 0;

Parameter

_Msg
Objek message yang akan dikirim secara sinkron.

Keterangan

Implementasi prosesor harus mengambil alih metode ini.

tunggu

Ketika dioverride di kelas turunan, menunggu hingga semua operasi asinkron selesai.

virtual void wait() = 0;

Keterangan

Implementasi prosesor harus mengambil alih metode ini.

Lihat juga

Namespace layanan konkurensi
Kelas ordered_message_processor