2010-01-27 02:48:42 +01:00
|
|
|
package com.metaweb.gridlock.process;
|
|
|
|
|
|
|
|
import java.util.LinkedList;
|
|
|
|
import java.util.List;
|
2010-02-01 04:22:35 +01:00
|
|
|
import java.util.Properties;
|
|
|
|
|
|
|
|
import org.json.JSONException;
|
2010-02-01 20:16:09 +01:00
|
|
|
import org.json.JSONWriter;
|
2010-01-27 02:48:42 +01:00
|
|
|
|
2010-02-01 20:16:09 +01:00
|
|
|
import com.metaweb.gridlock.Jsonizable;
|
|
|
|
|
|
|
|
public class ProcessManager implements Jsonizable {
|
2010-01-27 02:48:42 +01:00
|
|
|
protected List<Process> _processes = new LinkedList<Process>();
|
|
|
|
|
|
|
|
public ProcessManager() {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
2010-02-01 20:16:09 +01:00
|
|
|
|
|
|
|
@Override
|
|
|
|
public void write(JSONWriter writer, Properties options)
|
|
|
|
throws JSONException {
|
2010-02-01 04:22:35 +01:00
|
|
|
|
2010-02-01 20:16:09 +01:00
|
|
|
writer.object();
|
|
|
|
writer.key("processes"); writer.array();
|
2010-02-01 04:22:35 +01:00
|
|
|
for (Process p : _processes) {
|
2010-02-01 20:16:09 +01:00
|
|
|
p.write(writer, options);
|
2010-02-01 04:22:35 +01:00
|
|
|
}
|
2010-02-01 20:16:09 +01:00
|
|
|
writer.endArray();
|
2010-02-01 04:22:35 +01:00
|
|
|
|
2010-02-01 20:16:09 +01:00
|
|
|
writer.endObject();
|
2010-02-01 04:22:35 +01:00
|
|
|
}
|
2010-02-01 20:16:09 +01:00
|
|
|
|
2010-01-27 02:48:42 +01:00
|
|
|
public boolean queueProcess(Process process) {
|
|
|
|
if (process.isImmediate() && _processes.size() == 0) {
|
|
|
|
process.performImmediate();
|
|
|
|
return true;
|
|
|
|
} else {
|
|
|
|
_processes.add(process);
|
2010-02-01 09:31:50 +01:00
|
|
|
|
|
|
|
update();
|
|
|
|
|
2010-01-27 02:48:42 +01:00
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
2010-02-01 04:22:35 +01:00
|
|
|
|
|
|
|
public void onDoneProcess(Process p) {
|
2010-02-01 09:31:50 +01:00
|
|
|
_processes.remove(p);
|
2010-02-01 04:22:35 +01:00
|
|
|
update();
|
|
|
|
}
|
|
|
|
|
|
|
|
protected void update() {
|
|
|
|
while (_processes.size() > 0) {
|
|
|
|
Process p = _processes.get(0);
|
|
|
|
if (p.isImmediate()) {
|
|
|
|
p.performImmediate();
|
|
|
|
_processes.remove(0);
|
|
|
|
} else if (p.isDone()) {
|
|
|
|
_processes.remove(0);
|
|
|
|
} else {
|
|
|
|
if (!p.isRunning()) {
|
|
|
|
p.startPerforming(this);
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2010-01-27 02:48:42 +01:00
|
|
|
}
|