A C++ concurrency model  for message process