Uploaded image for project: 'JGroups'
  1. JGroups
  2. JGRP-2150

More efficient message adding and draining

    XMLWordPrintable

Details

    • Enhancement
    • Resolution: Done
    • Major
    • 4.0
    • None

    Description

      In NAKACK2, UNICAST3 and in MaxOneThreadPerSenderPolicy, we have a pattern where one or more producers add messages (to a table in NAKACK2 and UNICAST3, or to a MessageBatch in MaxOneThreadPerSenderPolicy) and then only a single thread can remove and deliver messages up the stack.

      This requires synchronization around (1) determining the thread which will remove messages, (2) adding messages to the table (or batch) and (3) removing messages from the table or batch.

      Unit tests DrainTest and MessageBatchDrainTest show how a simple AtomicInteger can be used to do this.

      Attachments

        Activity

          People

            rhn-engineering-bban Bela Ban
            rhn-engineering-bban Bela Ban
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: