Class MaxOneThreadPerSender

  • All Implemented Interfaces:
    MessageProcessingPolicy
    Direct Known Subclasses:
    UnbatchOOBBatches

    public class MaxOneThreadPerSender
    extends SubmitToThreadPool
    MessageProcessingPolicy which processes regular messages and message batches by assigning a max of 1 thread per message from the same sender. So if we have senders A, B, C and D, we'll have no more than 4 threads handling regular unicasts and 4 threads handling regular multicasts.

    See JGRP-2143 for details.
    When using virtual threads, we probably don't need this anymore, and can use a virtual thread to send messages / message batches directly up to UNICAST or NAKACK.

    Since:
    4.0
    Author:
    Bela Ban