ResetExpiredJobsRunnable (Activiti :: Engine 7.2.3 API)

java.lang.Object
- org.activiti.engine.impl.asyncexecutor.ResetExpiredJobsRunnable

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

TenantAwareResetExpiredJobsRunnable
```
public class ResetExpiredJobsRunnable
extends Object
implements Runnable
```
Runnable that checks the Job entities periodically for 'expired' jobs. When a job is executed, it is first locked (lock owner and lock time is set). A job is expired when this lock time is exceeded. This can happen when an executor goes down before completing a task. This runnable will find such jobs and reset them, so they can be picked up again.

- Field Summary
  
  Fields
  Modifier and Type Field Description
  
  protected AsyncExecutor asyncExecutor
  
  protected boolean isInterrupted
  
  protected AtomicBoolean isWaiting
  
  protected Object MONITOR
- Constructor Summary
  
  Constructors
  Constructor Description
  
  ResetExpiredJobsRunnable(AsyncExecutor asyncExecutor)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void run()
  
  void stop()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

asyncExecutor

protected final AsyncExecutor asyncExecutor

isInterrupted

protected volatile boolean isInterrupted

MONITOR
```
protected final Object MONITOR
```

isWaiting

protected final AtomicBoolean isWaiting

Constructor Detail

ResetExpiredJobsRunnable

public ResetExpiredJobsRunnable(AsyncExecutor asyncExecutor)

Method Detail
- run
```
public void run()
```
  Specified by:
  
  run in interface Runnable
- stop
```
public void stop()
```