标签:ext this extends new oid roc exception 变量 throw
java多线程执行任务时,为了避免任务的重复执行,可以通过synchronized关键字处理共享成员变量,具体代码如下:
// 多线程处理任务方法
private void processMultiTask(final List<LogStatTask> list, int threadCount) throws Exception {
// 根据设定的线程数处理任务列表
for (int i = 0; i < threadCount; i++) { TaskThread thread = new TaskThread(list); thread.start(); } }
// 任务处理线程类 class TaskThread extends Thread { private List<LogStatTask> taskList = null;
// 根据线程类成员变量创建构造函数 public TaskThread(List<LogStatTask> taskList) { super(); this.taskList = taskList; } public void run() { while (true) { LogStatTask task;
// 锁住taskList任务表对象,确保只有一个线程正在操作它 synchronized (taskList) {
// 如果任务列表为空,则退出执行 if (CollectionUtils.isEmpty(taskList)) { break; }
// 从任务任务列表中取出一个待执行的任务,并从任务表中移除 task = taskList.remove(0); } // 释放掉对taskList的锁,以便其他线程对其操作,本线程则根据task进行相应的处理 } } }
标签:ext this extends new oid roc exception 变量 throw
原文地址:http://www.cnblogs.com/dali-lyc/p/7457715.html