my $iq = $control->input_queue;
  my $oq = $control->output_queue;
  threads->new(sub {
    ...
    // use $iq/$oq in here.
    ...
  });