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.