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, tempatkan pesan ke blok secara asinkron.
sync_send	Ketika ditimpa di kelas turunan, tempatkan pesan ke blok secara sinkron.
Tunggu	Ketika ditimpa di kelas turunan, menunggu semua operasi asinkron selesai.

Metode yang Dilindungi

Nama	Deskripsi
process_incoming_message	Saat ditimpa di kelas turunan, lakukan pemrosesan meneruskan pesan ke dalam blok. Dipanggil sekali setiap kali pesan baru ditambahkan dan antrean ditemukan kosong.

Hierarki Warisan

message_processor

Persyaratan

Header: agents.h

Namespace: konkurensi

async_send

Ketika ditimpa di kelas turunan, tempatkan pesan ke 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.

process_incoming_message

Saat ditimpa di kelas turunan, lakukan pemrosesan meneruskan pesan ke dalam 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 ditimpa di kelas turunan, tempatkan 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 ditimpa di kelas turunan, menunggu 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