Method Func

phxrpc/rpc/test_thread_queue.cpp:52–62

    }

    void Func(size_t id) {
        int n = 0;
        do {
            bool succ = thd_queue_->pluck(n);
            if (succ) {
                printf("thread_id(%zu) value(%d)\n", id, n);
            } else {
                break;
            }
        } while (!thd_queue_->empty());
    }

  private:
    ThdQueue<int> * thd_queue_;