[jboss-jira] [JBoss JIRA] (WFLY-12581) Optimize distributed web/ejb expiration schedulers

[Paul Ferraro (Jira)]

    [ https://issues.jboss.org/browse/WFLY-12581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13789779#comment-13789779 ] 

Paul Ferraro edited comment on WFLY-12581 at 9/26/19 1:01 PM:
--------------------------------------------------------------

[~flavia.rainone] Applying the new expiration scheduler to the EJB simple cache effectively doubles the performance of @Stateful EJB invocations under load.  See attached chart.


was (Author: pferraro):
Applying this new expiration scheduler to the EJB simple cache effectively doubles the performance of @Stateful EJB invocations under load.  See attached chart.

> Optimize distributed web/ejb expiration schedulers
> --------------------------------------------------
>
>                 Key: WFLY-12581
>                 URL: https://issues.jboss.org/browse/WFLY-12581
>             Project: WildFly
>          Issue Type: Enhancement
>          Components: Clustering
>    Affects Versions: 18.0.0.Beta1
>            Reporter: Paul Ferraro
>            Assignee: Paul Ferraro
>            Priority: Major
>         Attachments: EJB DistributableCache (passivating).png, EJB SimpleCache.png, Schedulers for distributed workloads.png, Schedulers for local workloads.png
>
>
> WFLY-12321 added a new expiration scheduler implementation for SFSBs specifically optimized for non-distributed environments.  The key features of this implementations are:
> * Uses a single scheduled task instead of a scheduled task per SFSB
> * Uses a double-linked list to track SFSBs to be expired
> Because most scheduled tasks will be canceled before they are executed, the performance of a given scheduler implementation is primarily limited by the cost of insertion and removal into the backing data structure.  The goal of this jira is to generalize the scheduler implementation introduced by WFLY-12321 such that it can be used for scheduling of both local and distributed web sessions and SFSBs.
> In the scheduler implemented as part of WFLY-12321, the use of a linked queue is based on the following assumptions:
> # All SFSB using a given scheduler use the same @StatefulTimeout
> # A given call to Scheduler.schedule(...) is always the last item to be scheduled
> Unfortunately, the second assumption is not valid for distributed SFSBs as a member may assume the responsibility of expiring a SFSB previously owned by another member.
> Additionally, the second assumption is not valid for local nor distributed web sessions, as a given web session can override the default session timeout of the application.
> This jira proposes the following:
> * Generalize the Scheduler interface for reuse between SFSBs and web sessions.
> * Generalize the new local scheduler implementation such that the same scheduler can support both local and distributed objects using different data structures for tracking scheduled items
> * Replace ExpirationTracker with a ConcurrentDirectDeque to support local case, which has O(1) add/remove characteristics
> ** ConcurrentDirectDeque outperforms ExpirationTracker under concurrent load (see attached graph)
> * Local web sessions and all distributed use cases will store scheduled entries within a ConcurrentSkipListSet, which has O(log N) add/remove characteristics



--
This message was sent by Atlassian Jira
(v7.13.8#713008)