Public Member Functions | |
void | Join () |
ProducerThread (grpc_core::InfLenFIFOQueue *queue, int start_index, int num_items) | |
void | Start () |
~ProducerThread () | |
Private Member Functions | |
void | Run () |
Private Attributes | |
WorkItem ** | items_ |
int | num_items_ |
grpc_core::InfLenFIFOQueue * | queue_ |
int | start_index_ |
grpc_core::Thread | thd_ |
Definition at line 39 of file mpmcqueue_test.cc.
|
inline |
Definition at line 41 of file mpmcqueue_test.cc.
|
inline |
Definition at line 49 of file mpmcqueue_test.cc.
|
inline |
Definition at line 58 of file mpmcqueue_test.cc.
|
inlineprivate |
Definition at line 61 of file mpmcqueue_test.cc.
|
inline |
Definition at line 57 of file mpmcqueue_test.cc.
|
private |
Definition at line 73 of file mpmcqueue_test.cc.
|
private |
Definition at line 70 of file mpmcqueue_test.cc.
|
private |
Definition at line 71 of file mpmcqueue_test.cc.
|
private |
Definition at line 69 of file mpmcqueue_test.cc.
|
private |
Definition at line 72 of file mpmcqueue_test.cc.