如何解决获得对线程的控制权，然后杀死它
我有一个关于Java线程的问题。在我的代码中...
client.doSth();
// now need to get hold of the thread that is initiated by \'client\'
(get a reference to the \'client\' thread)
// now kills it
(kills the \'client\' thread)
...
解决方法
编辑：
重读问题后，我不确定是否可以访问客户端代码。如果这样做，那么您可以对其进行修改，甚至不使用线程，而是使用
java.util.concurrent.ExecutorService
ThreadGroup g=new ThreadGroup(\"client X group\");
Runnable r=new Runnable(){
public void run(){
client.doSmth();//assuming a new thread is started...
}
}
Thread t= new Thread(g,r,\"clientStarter\");
t.start();
//stopping,last resort code,it\'s usually more complicated than just thread.stop,though
//now you can enumerate threads of the ThreadGroup
synchronized(g){//sync ensures no more threads will be created,use it w/ extreme caution
Thread[] threads = new Thread[g.activeCount()];
for(Thread thread:threads){
if(thread==null) break;
thread.stop();//
//cannot join in sync of ThreadGroup,do not use it here
}
}
// Find the root thread group
ThreadGroup root = Thread.currentThread().getThreadGroup().getParent();
while (root.getParent() != null) {
root = root.getParent();
}
// Visit each thread group
visit(root,0);
// This method recursively visits all thread groups under `group\'.
public static void visit(ThreadGroup group,int level) {
// Get threads in `group\'
int numThreads = group.activeCount();
Thread[] threads = new Thread[numThreads*2];
numThreads = group.enumerate(threads,false);
System.out.println(\" \");
// Enumerate each thread in `group\'
for (int i=0; i<numThreads; i++) {
// Get thread
Thread thread = threads[i];
System.out.println(thread.toString());
}
// Get thread subgroups of `group\'
int numGroups = group.activeGroupCount();
ThreadGroup[] groups = new ThreadGroup[numGroups*2];
numGroups = group.enumerate(groups,false);
// Recursively visit each subgroup
for (int i=0; i<numGroups; i++) {
visit(groups[i],level+1);
}
}
System.out.println(thread.dumpStack());
int idToKill = 2;
int active = Thread.activeCount();
System.out.println(\"currently active threads: \" + active);
Thread all[] = new Thread[active];
Thread.enumerate(all);
for (int i = 0; i < active; i++) {
System.out.println(i + \": \" + all[i]);
if(idToKill == i)
((Thread) all[i]).interrupt();
}
public class Client(){
private Thread t;
volatile private boolean stop;//volatile to ensure visibility across threads
public doSth(){
stop=false;
Runnable r = new Runnable(){
@Override
public void run(){
while(!stop){
//do stuff and periodically and ensure that interrupts bubble through
}
}
};
t = new Thread(r);
t.start();
}
public void stopSht(){
stop=true;
t.interupt();
}
}
import java.io.IOException;
import java.util.Arrays;
import com.esotericsoftware.kryonet.Client;
import com.esotericsoftware.kryonet.Server;
public class KryonetAndThreads {
public static void main(String[] args) throws IOException,InterruptedException {
Server s = new Server();
s.start();
s.bind(1927);
printThreads(\"server started\");
Client c = new Client();
c.start();
c.connect(5000,\"LOCALHOST\",1927);
printThreads(\"client connected\");
Server s1 = s;
s.stop();
printThreads(\"server stopped\");
s = new Server();
s.start();
s.bind(1928);
printThreads(\"new server started\"); // new server thread will be last on
// the list.
c.stop();
printThreads(\"client stopped\");
c.start();
c.connect(5000,\"localhost\",1928);
printThreads(\"client connected to second server\");
c.stop();
s.stop();
s1.stop();
printThreads(\"both stopped\");
}
private static void printThreads(String message)
throws InterruptedException {
// tick:
Thread.sleep(2000L);
Thread[] threads = new Thread[Thread.activeCount()];
Thread.enumerate(threads);
System.out.println(message + \" : \" + Arrays.asList(threads));
}
}
doSth()
Thread t = client.doSth();
t.interrupt();
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。