mirror of
https://github.com/OpenHFT/Chronicle-Map.git
synced 2021-09-13 01:26:12 +00:00
Remove <p/>
This commit is contained in:
@@ -167,7 +167,7 @@ public final class ChronicleMapBuilder<K, V> implements
|
||||
/**
|
||||
* Default timeout is 1 minute. Even loopback tests converge often in the course of seconds,
|
||||
* let alone WAN replication over many nodes might take tens of seconds.
|
||||
* <p/>
|
||||
* <p>
|
||||
* TODO review
|
||||
*/
|
||||
long cleanupTimeout = 1;
|
||||
|
||||
@@ -46,13 +46,13 @@ import static net.openhft.chronicle.algo.bytes.Access.checkedBytesStoreAccess;
|
||||
* shared map (using ChronicleMap) to maintain shared data across any processes
|
||||
* which use a ProcessInstanceLimiter, and checking on startup and regularly
|
||||
* after whether it is allowed to run.
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>Typically, you need to specify two things to create an instance of
|
||||
* ProcessInstanceLimiter: a path to a file that will hold the shared map; and a
|
||||
* callback object (an instance implementing ProcessInstanceLimiter.Callback) to
|
||||
* handle the various possible callback messages that the ProcessInstanceLimiter
|
||||
* can generate.
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>Once you have a ProcessInstanceLimiter instance, you specify a type of
|
||||
* process (any string) which will be limited to up to N processes running at
|
||||
* the same time by calling the setMaxNumberOfProcessesOfType() method. Finally
|
||||
@@ -60,18 +60,18 @@ import static net.openhft.chronicle.algo.bytes.Access.checkedBytesStoreAccess;
|
||||
* startingProcessOfType(X). This last is deliberately not done automatically as
|
||||
* you may wish for one type of process to define limitations on other types of
|
||||
* processes.
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>The are some convenience methods which allow you to quickly specify a limit
|
||||
* without consideration of the above. For example, if during your application
|
||||
* startup you call ProcessInstanceLimiter.limitTo(2), then you need not call
|
||||
* anything else and you have limited your application to running at most 2 JVM
|
||||
* instances of your application. Under the covers, this call is identical to
|
||||
* the sequence:
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>ProcessInstanceLimiter limiter = new ProcessInstanceLimiter();
|
||||
* limiter.setMaxNumberOfProcessesOfType(processType,numProcesses);
|
||||
* limiter.startingProcessOfType(processType);
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>This:
|
||||
* 1. Creates a shared file called ProcessInstanceLimiter_DEFAULT_SHARED_MAP_ in
|
||||
* the temp directory to hold an instance of ChronicleMap
|
||||
@@ -159,7 +159,7 @@ public class ProcessInstanceLimiter implements Runnable {
|
||||
|
||||
/**
|
||||
* Convenience method.
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>Create a ProcessInstanceLimiter instance which is limited to one OS
|
||||
* process instance of the DEFAULT type. This will enforce that any JVM on
|
||||
* the same box which runs the code
|
||||
@@ -175,7 +175,7 @@ public class ProcessInstanceLimiter implements Runnable {
|
||||
|
||||
/**
|
||||
* Convenience method.
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>Create a ProcessInstanceLimiter instance which is limited to
|
||||
* "numProcesses" OS process instances of the DEFAULT type. This will
|
||||
* enforce that any JVM on the same box which runs the code
|
||||
@@ -194,7 +194,7 @@ public class ProcessInstanceLimiter implements Runnable {
|
||||
|
||||
/**
|
||||
* Convenience method.
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>Create a ProcessInstanceLimiter instance which is limited to
|
||||
* "numProcesses" OS process instances of the "processType" type. This will
|
||||
* enforce that any JVM on the same box which runs the code
|
||||
@@ -532,7 +532,7 @@ public class ProcessInstanceLimiter implements Runnable {
|
||||
/**
|
||||
* The Data object holds an array of timestamps and a maximum number of
|
||||
* processes allowed to be running concurrently
|
||||
* <p/>
|
||||
* <p>
|
||||
* <p>The Timelock field is just for locking the time field
|
||||
*/
|
||||
public interface Data {
|
||||
|
||||
Reference in New Issue
Block a user