当前位置: 代码迷 >> J2EE >> java concurrent多线程,该如何解决
  详细解决方案

java concurrent多线程,该如何解决

热度:122   发布时间:2016-04-21 23:22:05.0
java concurrent多线程

import java.net.MalformedURLException;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class MyExecutor extends Thread {
String name;

public MyExecutor(String s) throws MalformedURLException, RemoteException,
NotBoundException {
this.name = s;
}

public void run() {
try {
System.out.println(Thread.currentThread().getName());
System.out.println(" start....");
System.out.println(name);
System.out.println("result:" + s);
Thread.sleep((int) (Math.random() * 1000));
System.out.println(" end...");
} catch (Exception e) {
e.printStackTrace();
}
}

public static void main(String args[]) throws MalformedURLException,
RemoteException, NotBoundException {
ExecutorService service = Executors.newFixedThreadPool(4);

Queue<String> allTasks = new ConcurrentLinkedQueue<String>();
allTasks.offer("1111");
allTasks.offer("2222");
allTasks.offer("3333");
allTasks.offer("4444");
allTasks.offer("5555");
allTasks.offer("6666");

String str;

while ((str = allTasks.poll()) != null) {
service.execute(new MyExecutor(str));
System.out.println(str);
}

System.out.println("submit finish");
service.shutdown();
}
}


上述代码是用concurrent包写了个多线程,请问下有什么问题没?

------解决方案--------------------
目测没啥问题,LZ想测什么场景呢?CPU处理速度很快的,你的简单线程也许一execute就完成了,不会超出队列的。
------解决方案--------------------
引用:
目测没啥问题,LZ想测什么场景呢?CPU处理速度很快的,你的简单线程也许一execute就完成了,不会超出队列的。

不好意思,没注意还有句:Thread.sleep((int) (Math.random() * 1000));
这样就会超过4个线程了,呵呵
------解决方案--------------------
System.out.println("result:" + name);
------解决方案--------------------
关键是你要问什么问题?遇到什么不对或不理解的问题

------解决方案--------------------
引用:
现在有个问题就是在线程中调用外部方法,这个方法会返回个字符串("true"或"false"),如果为false的话,要停止队列的循环,该如何实现?


你是要停止队列循环,加个voliate isRunning=true的标志就行了啊

while(isRunning&&xxxxx){
....
}
当你的线程返回字符串为false时,改变isRunning=false则可以停止掉你队列的循环。

ps:楼主这里最好将allTasks.poll放到while循环里面,这里你的while条件来看,你的程序在跑完线程后,自动就会结束掉你的队列循环。


还有一种停止掉你队列的循环是,在你的线程中加入一个结束消息,例如结束消息为str="End"
然后再你的循环中每次去判断
if("End".equals(result)){
break;
}
若是,则break掉你的循环。
  相关解决方案