Skip to content

P
Paddle

PaddlePaddle / Paddle
1 年多 前同步成功

通知 2302
Star 20931
Fork 5422
P
Paddle

Add modification to Channel to support Select OP !9084

!9084 已合并 由 saxon_zh@saxon_zh 创建

Created by: abhinavarora

Fixes https://github.com/PaddlePaddle/Paddle/issues/8815 Fixes https://github.com/PaddlePaddle/Paddle/issues/8864 Fixes https://github.com/PaddlePaddle/Paddle/issues/8863 Fixes https://github.com/PaddlePaddle/Paddle/issues/9083

This PR does the following:

  1. Implement a non-blocking CanSend and CanReceive for Channels
  2. Exposes methods to the channel to externally add tasks on SendQueue and RecvQueue. These will be called by the Select op
  3. Add IsClosed method, that will be used by select op
  4. Allows QueueMessage to support callbacks. This callback will be provided by the select op. The callback will be used by the select op to keep a track of the case that is executed.
  5. Provides the ability to share condition variable in the QueueMessage for different channels.