File tree Expand file tree Collapse file tree 2 files changed +1
-10
lines changed
include/rapidsmpf/shuffler Expand file tree Collapse file tree 2 files changed +1
-10
lines changed Original file line number Diff line number Diff line change @@ -53,16 +53,6 @@ class FinishCounter {
5353 * `wait*` methods. And be very careful if acquiring locks. Ideally it should be used
5454 * to signal a separate thread to do the actual processing (eg. WaitHand).
5555 *
56- * @note When a callback is registered, it will be identified by the
57- * FinishedCbId returned. So, if a callback needs to be preemptively canceled,
58- * the corresponding identifier needs to be provided.
59- *
60- * @note Every callback will be called as and when each partition is finished. If
61- * there were finished partitions before the callback was registered, the callback
62- * will be called for them immediately by the caller thread. Else, the callback will
63- * be called by the progress thread (Therefore, it will be called
64- * `n_local_partitions_` times in total).
65- *
6656 * @note Caller needs to be careful when using both callbacks and wait* methods
6757 * together.
6858 */
Original file line number Diff line number Diff line change @@ -92,6 +92,7 @@ FinishCounter::FinishCounter(
9292)
9393 : nranks_{nranks},
9494 finished_callback_{std::forward<FinishedCallback>(finished_callback)} {
95+ // Initially, none of the partitions are ready to wait on.
9596 goalposts_.reserve (local_partitions.size ());
9697 for (auto pid : local_partitions) {
9798 goalposts_.emplace (pid, PartitionInfo{});
You can’t perform that action at this time.
0 commit comments