Uploaded image for project: 'Apache RocketMQ'
  1. Apache RocketMQ
  2. ROCKETMQ-306

Specify thread's name of DefaultMQProducerImpl's checkExecutor

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Critical
    • Resolution: Invalid
    • 4.1.0-incubating
    • None
    • rocketmq-client
    • None

    Description

      Current the way of initializing checkExecutor didn't specify a threadFactory with provided a meaningful thread name which is very helpful to trace the error information,so we better assign a name of this thread pool.

              this.checkExecutor = new ThreadPoolExecutor(
                  producer.getCheckThreadPoolMinSize(),
                  producer.getCheckThreadPoolMaxSize(),
                  1000 * 60,
                  TimeUnit.MILLISECONDS,
                  this.checkRequestQueue);
      

      Attachments

        Issue Links

          Activity

            People

              vintagewang Xiaorui Wang
              acoder2014 acoder2014
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: