threads->create ("read_data", $queue, $connection)->detach;