e2a7f2dc93
https://jira.talendforge.org/browse/TDI-30996 lockWrite is the lock provided by iterate with parallel, one lockWrite for one Iterate connector
43 lines
1.2 KiB
Java
43 lines
1.2 KiB
Java
// ============================================================================
|
|
//
|
|
// Copyright (C) 2006-2014 Talend Inc. - www.talend.com
|
|
//
|
|
// This source code is available under agreement available at
|
|
// %InstallDIR%\features\org.talend.rcp.branding.%PRODUCTNAME%\%PRODUCTNAME%license.txt
|
|
//
|
|
// You should have received a copy of the agreement
|
|
// along with this program; if not, write to Talend SA
|
|
// 9 rue Pages 92150 Suresnes, France
|
|
//
|
|
// ============================================================================
|
|
package routines.system;
|
|
|
|
public class TalendThread extends Thread {
|
|
|
|
protected Object[] lockWrite;
|
|
|
|
public void assignLock(Object[] lockWrite) {
|
|
this.lockWrite = lockWrite;
|
|
}
|
|
|
|
public TalendThreadPool talendThreadPool = null;
|
|
|
|
public Integer errorCode = null;
|
|
|
|
public String status = ""; //$NON-NLS-1$
|
|
|
|
public Exception exception = null;
|
|
|
|
// this is a template for Iterate Parallel
|
|
@Override
|
|
public void run() {
|
|
try {
|
|
|
|
} catch (Exception e) {
|
|
talendThreadPool.setErrorThread(this);
|
|
talendThreadPool.stopAllWorkers();
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
}
|