Utility functions for adaptively executing concurrent workflows

Utility functions for adaptively executing concurrent workflows