线程相关内容 批量复核触发线程
--在方法内部启动线程
for(List<TaskInstanceBean> o : oList) {
?? BatchCheckThread t = new BatchCheckThread();
?? t.setComment(comment);
?? t.setStrDN(strDN);
? ?t.setTibs(o);
?? t.setUser(this.getCurrentUser(request));
?
? ?t.setCountDown(end);
? ?new Thread(t).start();
}
?
BatchCheckThread? 是一个内部类，然后在里面添加线程的代码
?
--跟踪哪个线程的里面执行的情况
Logger.getLogger(BatchCheckThread.class).info("开始执行线程：" + Thread.currentThread().getName() + ",条数：" + tibs.size());
?
--内部类里面执行线程
class BatchCheckThread implements Runnable {
?private String comment;
?private List<TaskInstanceBean> tibs;
?private User user;
?private String strDN;
?private CountDownLatch countDown = null;
?
?public void setCountDown(CountDownLatch countDown) {
??this.countDown = countDown;
?}
?public String getComment() {
??return comment;
?}
?public void setComment(String comment) {
??this.comment = comment;
?}
?public List<TaskInstanceBean> getTibs() {
??return tibs;
?}
?public void setTibs(List<TaskInstanceBean> tibs) {
??this.tibs = tibs;
?}
?public User getUser() {
??return user;
?}
?public void setUser(User user) {
??this.user = user;
?}
?public String getStrDN() {
??return strDN;
?}
?public void setStrDN(String strDN) {
??this.strDN = strDN;
?}
?@Override
?public void run() {
??try {
???long begin = System.currentTimeMillis();
???Logger.getLogger(BatchCheckThread.class).info("开始执行线程：" + Thread.currentThread().getName() + ",条数：" + tibs.size());
???execute();
???Logger.getLogger(BatchCheckThread.class).info("线程：" + Thread.currentThread().getName() + ",耗时：" + (System.currentTimeMillis() - begin) + " ms");
??} catch(Exception e) {
???new RuntimeException(e);
??} finally {
???if(null != countDown) countDown.countDown();
??}
?}
?
?private void execute() {
??if(null == tibs) return;
??for(TaskInstanceBean tib : tibs) {
???List<Transition> trans = tib.getAvailableTransitions();
???for(Transition tran : trans){
????String tansName = tran.getName();
????if(isCanApproval(comment, tib, tran)){
?????ServiceFactory.getInstance().getJbpmProcessService().handelTask(tib.getTaskInstanceId(), tansName, user, "批量"+tansName, strDN ,null);
?????break;
????}
???}
??}
?}
?
?private boolean isCanApproval(String comment, TaskInstanceBean tib, Transition tran) {
??if(tib.getTaskInstance().getName().equals("复核") && "同意".equals(comment)) {
???return "送审批".equals(tran.getName());
??}
??return tran.getName().equals(comment + tib.getTaskInstance().getName());
?}
}
?
?
