Package jadex.collection

Class LeaseTimeSet<E>

java.lang.Object
jadex.collection.LeaseTimeSet<E>
All Implemented Interfaces:
ILeaseTimeSet<E>, Iterable<E>, Collection<E>
public class LeaseTimeSet<E> extends Object implements ILeaseTimeSet<E>
Collection that remove elements after a lease time automatically.

  • Field Details

    • NONE

      public static final long NONE
      Constant for no leasetime.
      See Also:

    • UNSET

      public static final long UNSET
      Constant for unset leasetime (use global default otherwise no leasetime).
      See Also:

    • entries

      protected PriorityQueue<E> entries
      The entries.

    • times

      protected Map<E,jadex.common.Tuple2<Long,Long>> times
      The timestamps.

    • timer

      protected IDelayRunner timer
      The timer.

    • leasetime

      protected long leasetime
      The leasetime.

    • checker

      protected LeaseTimeSet<E>.Checker checker
      The current checker.

    • removecmd

      protected Consumer<jadex.common.Tuple2<E,Long>> removecmd
      The cleaner.

  • Constructor Details

    • LeaseTimeSet

      protected LeaseTimeSet()
      Create a new lease time handling object.

    • LeaseTimeSet

      protected LeaseTimeSet(long leasetime)
      Create a new lease time handling object.

    • LeaseTimeSet

      protected LeaseTimeSet(Consumer<jadex.common.Tuple2<E,Long>> removecmd)
      Create a new lease time handling object.

    • LeaseTimeSet

      protected LeaseTimeSet(long leasetime, Consumer<jadex.common.Tuple2<E,Long>> removecmd)
      Create a new lease time handling object.

    • LeaseTimeSet

      public LeaseTimeSet(long leasetime, Consumer<jadex.common.Tuple2<E,Long>> removecmd, IDelayRunner timer)
      Create a new lease time handling object.

  • Method Details

    • createLeaseTimeCollection

      public static <E> ILeaseTimeSet<E> createLeaseTimeCollection(long leasetime)
      Create a lease time collection.

    • createLeaseTimeCollection

      public static <E> ILeaseTimeSet<E> createLeaseTimeCollection(long leasetime, Consumer<jadex.common.Tuple2<E,Long>> removecmd)
      Create a lease time collection.

    • createLeaseTimeCollection

      public static <E> ILeaseTimeSet<E> createLeaseTimeCollection(long leasetime, boolean passive, Consumer<jadex.common.Tuple2<E,Long>> removecmd)
      Create a lease time collection.

    • createLeaseTimeCollection

      public static <E> ILeaseTimeSet<E> createLeaseTimeCollection(long leasetime, Consumer<jadex.common.Tuple2<E,Long>> removecmd, Object mutex)
      Create a lease time collection.

    • createLeaseTimeCollection

      public static <E> ILeaseTimeSet<E> createLeaseTimeCollection(long leasetime, Consumer<jadex.common.Tuple2<E,Long>> removecmd, boolean passive, IDelayRunner timer, boolean sync, Object mutex)
      Create a lease time collection.

    • setRemoveCommand

      public void setRemoveCommand(Consumer<jadex.common.Tuple2<E,Long>> cmd)
      Set the remove cmd.
      Specified by:
      setRemoveCommand in interface ILeaseTimeSet<E>

    • size

      public int size()
      Specified by:
      size in interface Collection<E>

    • isEmpty

      public boolean isEmpty()
      Specified by:
      isEmpty in interface Collection<E>

    • contains

      public boolean contains(Object o)
      Specified by:
      contains in interface Collection<E>

    • iterator

      public Iterator<E> iterator()
      Specified by:
      iterator in interface Collection<E>
      Specified by:
      iterator in interface Iterable<E>

    • toArray

      public Object[] toArray()
      Specified by:
      toArray in interface Collection<E>

    • toArray

      public <T> T[] toArray(T[] a)
      Specified by:
      toArray in interface Collection<E>

    • add

      public boolean add(E e)
      Specified by:
      add in interface Collection<E>

    • add

      public boolean add(E e, long leasetime)
      Description copied from interface: ILeaseTimeSet
      Add a new entry.
      Specified by:
      add in interface ILeaseTimeSet<E>
      Parameters:
      e - The entry.
      leasetime - The leasetime.
      Returns:
      True, if new entry.

    • remove

      public boolean remove(Object o)
      Specified by:
      remove in interface Collection<E>

    • containsAll

      public boolean containsAll(Collection<?> c)
      Specified by:
      containsAll in interface Collection<E>

    • addAll

      public boolean addAll(Collection<? extends E> c)
      Specified by:
      addAll in interface Collection<E>

    • removeAll

      public boolean removeAll(Collection<?> c)
      Specified by:
      removeAll in interface Collection<E>

    • retainAll

      public boolean retainAll(Collection<?> c)
      Specified by:
      retainAll in interface Collection<E>

    • clear

      public void clear()
      Specified by:
      clear in interface Collection<E>

    • equals

      public boolean equals(Object o)
      Specified by:
      equals in interface Collection<E>
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Get the hashcode.
      Specified by:
      hashCode in interface Collection<E>
      Overrides:
      hashCode in class Object

    • update

      public boolean update(E e)
      Add a new entry or update an existing entry.
      Specified by:
      update in interface ILeaseTimeSet<E>
      Parameters:
      entry - The entry.
      Returns:
      True, if new entry.

    • update

      public boolean update(E e, long leasetime)
      Add a new entry or update an existing entry.
      Specified by:
      update in interface ILeaseTimeSet<E>
      Parameters:
      entry - The entry.
      Returns:
      True, if new entry.

    • touch

      public void touch(E e)
      Update the timestamp of e.
      Specified by:
      touch in interface ILeaseTimeSet<E>
      Parameters:
      entry - The entry.

    • touch

      public void touch(E e, long leasetime)
      Update the timestamp of e.
      Specified by:
      touch in interface ILeaseTimeSet<E>
      Parameters:
      entry - The entry.

    • getExpirationTime

      protected Long getExpirationTime(long leasetime)
      Get the expiration time.
      Parameters:
      leasetime -
      Returns:

    • checkStale

      public void checkStale()
      Start removing discovered proxies.

    • doWaitFor

      public Runnable doWaitFor(long delay, Runnable step)
      Overriden wait for to not use platform clock.

    • getClockTime

      protected long getClockTime()
      Get the current time.

    • getLeaseTime

      public long getLeaseTime()
      Get the leasetime.

    • getLeaseTime

      public Long getLeaseTime(E entry)
      Get the leasetime.

    • dispose

      public void dispose()
      Release all resources.

    • toString

      public String toString()
      Get the string representation.
      Overrides:
      toString in class Object

    • main

      public static void main(String[] args)
      Main for testing.