| 27 | } |
| 28 | |
| 29 | thread_qitem* thread_queue::pop(int wait_ms /* = -1 */) |
| 30 | { |
| 31 | int wait_sec = wait_ms / 1000; |
| 32 | int wait_usec = (wait_ms % 1000) * 1000; |
| 33 | return (thread_qitem*) acl_aqueue_pop_timedwait( |
| 34 | queue_, wait_sec, wait_usec); |
| 35 | } |
| 36 | |
| 37 | int thread_queue::qlen() const |
| 38 | { |
no test coverage detected