ProcessManager (OpenRefine 4.0-SNAPSHOT API)

java.lang.Object
- org.openrefine.process.ProcessManager

public class ProcessManager
extends Object

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class ProcessManager.ExceptionMessage

Field Summary

Fields
Modifier and Type Field Description

protected List<Process> _processes

Constructor Summary

Constructors
Constructor Description

ProcessManager()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancelAll()`
`protected com.google.common.util.concurrent.ListeningExecutorService`	`getExecutorService()`
`Process`	`getProcess(int processId)`	Gets the process with the given process id.
`Process`	`getProcess(ChangeDataId changeDataId)`	Gets any process that is fetching the supplied change data.
`List<Process>`	`getProcesses()`
`boolean`	`hasPending()`	Is there any process in the queue (potentially running)?
`void`	`onDoneProcess(Process p)`
`void`	`queueProcess(Process process)`
`void`	`shutdown()`
`void`	`update()`

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

Field Detail
- _processes
```
protected List<Process> _processes
```

Constructor Detail
- ProcessManager
```
public ProcessManager()
```

Method Detail

shutdown
```
public void shutdown()
```

getProcesses
```
public List<Process> getProcesses()
```

queueProcess

public void queueProcess(Process process)

hasPending
```
public boolean hasPending()
```
Is there any process in the queue (potentially running)?

onDoneProcess

public void onDoneProcess(Process p)

cancelAll
```
public void cancelAll()
```

getProcess
```
public Process getProcess(int processId)
```
Gets the process with the given process id.

Throws:

IllegalArgumentException - if the process cannot be found

getProcess
```
public Process getProcess(ChangeDataId changeDataId)
```
Gets any process that is fetching the supplied change data.

Returns:

null if no such process can be found

update
```
public void update()
```

getExecutorService

protected com.google.common.util.concurrent.ListeningExecutorService getExecutorService()