Searched refs:num_producers_ (Results 1 – 7 of 7) sorted by relevance
75 : num_producers_(n_producers), num_consumers_(n_consumers) { in Connector()87 queues_.Init(num_producers_, queue_capacity); in Connector()104 pop_from_ = (pop_from_ + 1) % num_producers_; in Pop()152 << "\nNumber of producers : " << num_producers_ << "\n"; in Print()200 int32_t num_producers_; variable
61 for (int offset = 1; offset <= num_producers_; offset++) { in Pop()62 int32_t nextQueueIndex = (pop_from_ + offset) % num_producers_; in Pop()
64 for (int offset = 1; offset <= num_producers_; offset++) { in Pop()65 int32_t nextQueueIndex = (pop_from_ + offset) % num_producers_; in Pop()
85 pop_from_ = (pop_from_ + 1) % num_producers_;
30 num_producers_(num_workers), in ParallelOp()48 num_producers_ = 1; in CreateWorkerConnector()53 …worker_connector_ = std::make_unique<DbConnector>(num_workers_, num_producers_, worker_connector_s… in CreateWorkerConnector()
87 int32_t NumProducers() const override { return num_producers_; } in NumProducers()116 int32_t num_producers_; // The number of threads pushing to the out_connector_ variable
124 num_producers_ = num_workers_; in operator ()()128 DatasetOp::CreateConnector(num_producers_, num_workers_); in operator ()()