s434730/RandomSec
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Synchronize access to processes list - fixes #862

Browse Source
This commit is contained in:
Tom Morris 2014-04-05 12:36:40 -04:00
parent e3cdd160d0
commit 5799c3d92b
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
main/src/com/google/refine/process/ProcessManager.java
View File

@ -33,6 +33,7 @@ OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
package com.google.refine.process; package com.google.refine.process;
import java.util.Collections;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;
import java.util.Properties; import java.util.Properties;
@ -45,7 +46,7 @@ import com.google.refine.history.HistoryEntry;
import com.google.refine.history.HistoryProcess; import com.google.refine.history.HistoryProcess;
public class ProcessManager implements Jsonizable { public class ProcessManager implements Jsonizable {
protected List<Process> _processes = new LinkedList<Process>(); protected List<Process> _processes = Collections.synchronizedList(new LinkedList<Process>());
protected List<Exception> _latestExceptions = null; protected List<Exception> _latestExceptions = null;
public ProcessManager() { public ProcessManager() {
@ -58,8 +59,10 @@ public class ProcessManager implements Jsonizable {
writer.object(); writer.object();
writer.key("processes"); writer.array(); writer.key("processes"); writer.array();
for (Process p : _processes) { synchronized (_processes) {
p.write(writer, options); for (Process p : _processes) {
p.write(writer, options);
}
} }
writer.endArray(); writer.endArray();