def out_sender_thread
        Thread.start {
          log_info { "start out sender thread" }
          loop do
            if @r_io_out.closed?