[PD] threads in pd, dataflow