java多线程处理任务,该如何处理
日期：2014-05-20 浏览次数：20709 次
java多线程处理任务
现在有一堆任务，要求10个线程同时执行，每个任务只能被一个线程执行，直到把所有任务执行完毕。怎么写啊。哪个大哥帮写一下
------解决方案--------------------
你的线程只要不结束他就可以了，写了个例子，希望对你有帮助
------解决方案--------------------
现在有一堆任务，要求10个线程同时执行，每个任务只能被一个线程执行，直到把所有任务执行完毕。怎么写啊。哪个大哥帮写一下
------解决方案--------------------
你的线程只要不结束他就可以了，写了个例子，希望对你有帮助
package com.study.thread;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
public class ThreadRun {
public static List<String> tasks = Collections.synchronizedList(new ArrayList<String>());
public static List<Th> threads = Collections.synchronizedList(new ArrayList<Th>());
static{
for(int i = 0; i < 100; i++){
tasks.add("任务" + i);
}
for(int i = 0; i < 10; i++){
Th th = new Th();
th.setName("任务线程" + i);
th.start();
threads.add(th);
}
}
public static void main(String[] args) {
while(!tasks.isEmpty()){
String task = tasks.remove(0);
if(!threads.isEmpty()){
Th t = threads.remove(0);
t.setTask(task);
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Th extends Thread{
private String task;
public void run(){
while(!ThreadRun.tasks.isEmpty()){
if(task != null){
System.out.println("任务 ： [" + task + "]被[" + this.getName() + "]执行......");
task = null;
ThreadRun.threads.add(this);
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public void setTask(String task){
this.task = task;
}
}
------解决方案--------------------
package com.study.thread;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
public class ThreadRun {
public static List<String> tasks = Collections.synchronizedList(new ArrayList<String>());
public static List<Th> threads = Collections.synchronizedList(new ArrayList<Th>());
static{
for(int i = 0; i < 100; i++){
tasks.add("任务" + i);
}
for(int i = 0; i < 10; i++){
Th th = new Th();
th.setName("任务线程" + i);
th.start();
threads.add(th);
}
}
public static void main(String[] args) {
while(!tasks.isEmpty()){
if(!threads.isEmpty()){
String task = tasks.remove(0);
Th t = threads.remove(0);
t.setTask(task);
}
}
}
}
class Th extends Thread{
private String task;
public void run(){
while(!ThreadRun.tasks.isEmpty()){
if(task != null){
System.out.println("任务 ： [" + task + "]被[" + this.getName() + "]执行......");
task = null;
ThreadRun.threads.add(this);
}
}
if(task != null){
免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。
