search

TimelyDataflow / timely-dataflow

A modular implementation of timely dataflow in Rust
MIT License
3.25k stars 273 forks source link

Probe only retains weak handle to Rc #543

Closed antiguru closed 6 months ago

antiguru commented 6 months ago

The probe operator writes into a shared frontier, but it does so even if there is no other reference to the shared frontier. This change adjusts the behavior to only write to the shared frontier while there exists another reference.

frankmcsherry commented 6 months ago

Seems smart, thanks!