Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-12203

Reduce thread context switches in BeamFnControlClient

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • Missing
    • sdk-java-harness
    • None

    Description

      This class has a grpc observer that queues recieved messages on a LinkedBlockingQueue and then has a separate thread pulling from the the queue to add to an executor.

      Instead we could just add directly to the executor from the grpc stream, as the executor by default has an unbounded queue size (and there are comments indicating that a limited size executor can cause deadlocks otherwise)

      Attachments

        Issue Links

          Activity

            People

              scwhittle Sam Whittle
              scwhittle Sam Whittle
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 1.5h
                  1.5h