Worker (Java Client 4.18.0 API)

java.lang.Object
- io.split.engine.sse.workers.Worker<T>

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

FeatureFlagWorkerImp, SegmentsWorkerImp
```
public abstract class Worker<T>
extends Object
implements Runnable
```

Field Summary

Fields
Modifier and Type	Field	Description
`protected static org.slf4j.Logger`	`_log`
`protected LinkedBlockingQueue<T>`	`_queue`
`protected AtomicBoolean`	`_running`
`protected Thread`	`_thread`

Constructor Summary

Constructors
Constructor Description

Worker(String workerName)

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addToQueue(T element)`
`protected abstract void`	`executeRefresh(T element)`
`void`	`run()`
`void`	`start()`
`void`	`stop()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_log

protected static final org.slf4j.Logger _log

_queue

protected final LinkedBlockingQueue<T> _queue

_running
```
protected AtomicBoolean _running
```

_thread
```
protected Thread _thread
```

Constructor Detail
- Worker
```
public Worker(String workerName)
```

Method Detail

start
```
public void start()
```

stop
```
public void stop()
```

addToQueue
```
public void addToQueue(T element)
```

run
```
public void run()
```
Specified by:

run in interface Runnable

executeRefresh

protected abstract void executeRefresh(T element)