作者热门文章
- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我的 Java.NIO 套接字服务器中有一个线程池。我有时会收到运行时错误,例如 Connection reset by peer
或 Broken Pipe
等。
我的问题是:抛出异常时线程是否被杀死?如果是 - 是否在线程池中创建了一个新线程来代替被杀死的线程??
这是我的线程管理器:
import java.nio.channels.SocketChannel;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadsManager {
private ExecutorService threadPool = null;
private LiveConnectionsManager liveConnectionsManager;
private int threadPoolSize = 35; //number of tasks thread
public ThreadsManager(LiveConnectionsManager liveConnectionsManager) {
this.liveConnectionsManager = liveConnectionsManager;
threadPool = Executors.newFixedThreadPool(threadPoolSize);
ServerActions.threadPool = threadPool;
}
public void processNewMessage(SocketChannel socketChannel, Client client)
{
threadPool.execute(new MessagesProcessor(socketChannel, client, liveConnectionsManager));
}
public void closeConnection(SocketChannel socketChannel, Client client) {
threadPool.execute(new LogoutClient(socketChannel, client, null));
}
}
最佳答案
当您使用 ExecutorService 创建线程池时。
所以是,ExecutorService.newFixedThreadPool(..)确保线程数量在被任何异常/错误杀死时保持不变,并且有足够的任务等待线。下面来自 java 文档的文本清楚地说明了这一点:
直接来自 java 文档:newFixedThreadPool
创建一个线程池,该线程池重用固定数量的线程,这些线程在共享的无界队列中运行。 在任何时候,最多 nThreads 个线程将处于 Activity 状态处理任务。如果在所有线程都处于 Activity 状态时提交了额外的任务,它们将在队列中等待,直到有线程可用。如果任何线程在关闭之前的执行过程中因故障而终止,则如果需要执行后续任务,将有一个新线程取代它。池中的线程将一直存在,直到它被显式关闭。
http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/Executors.html#newFixedThreadPool(int )
关于Java 线程池 - 线程正在更新吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14415104/
我是一名优秀的程序员,十分优秀!