minor updates to internal handling of consumer threads