Package org.mycore.util.concurrent

Class MCRPrioritySupplier<T>

java.lang.Object

org.mycore.util.concurrent.MCRPrioritySupplier<T>

Type Parameters:

T - the type of results supplied by this supplier

All Implemented Interfaces:

Comparable<MCRPrioritizable>, Supplier<T>, MCRPrioritizable

public class MCRPrioritySupplier<T>
extends Object
implements Supplier<T>, MCRPrioritizable

A supplier with a priority. stackoverflow

Author:

Matthias Eichner

Constructor Summary

Constructors

Constructor	Description
MCRPrioritySupplier(Supplier<T> delegate, int priority)

Method Summary

Modifier and Type	Method	Description
T	get()
long	getCreated()
int	getPriority()	Returns the priority.
CompletableFuture<T>	runAsync(ExecutorService es)	use this instead of CompletableFuture.supplyAsync(Supplier, Executor) This method keep the priority

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.mycore.util.concurrent.MCRPrioritizable

compareTo

Constructor Details

MCRPrioritySupplier

public MCRPrioritySupplier(Supplier<T> delegate,
 int priority)

Method Details

get

public T get()

Specified by:

get in interface Supplier<T>

getPriority

public int getPriority()

Description copied from interface: MCRPrioritizable

Returns the priority.

Specified by:

getPriority in interface MCRPrioritizable

getCreated

public long getCreated()

Specified by:

getCreated in interface MCRPrioritizable

runAsync

public CompletableFuture<T> runAsync(ExecutorService es)

use this instead of CompletableFuture.supplyAsync(Supplier, Executor) This method keep the priority

Parameters:

es -

Returns: