1
我有2个线程由JBoss管理(没有启动方法)。我需要的是,如果他们中的一个进入循环,那么另一个必须能够杀死它。换句话说,我怎样才能从一个线程向另一个线程发送消息(或例外)?有独立的线程之间进行通信的方法吗?如何在两个线程之间进行通信
非常感谢您提前!
亲切的问候
我有2个线程由JBoss管理(没有启动方法)。我需要的是,如果他们中的一个进入循环,那么另一个必须能够杀死它。换句话说,我怎样才能从一个线程向另一个线程发送消息(或例外)?有独立的线程之间进行通信的方法吗?如何在两个线程之间进行通信
非常感谢您提前!
亲切的问候
一个使用BlockingQueue的最佳途径。您将不得不在主线程中初始化队列。我在下面的例子中写入了一个阻塞队列,并展示了如何从线程中的阻塞队列读取数据。这个例子可以很容易地适用于从线程中读取/写入阻塞队列。如果你想关闭你的线程,你可以给阻塞队列写一个标记值,当你的线程被读取时,它可以关闭。
的主要驱动力:
public static void main(String[] args) {
// A blocking queue used to pass strings to threads
BlockingQueue<Entry<String> sharedQueue = new LinkedBlockingQueue< String>();
// The number of cores available on the running machine
// Note: if Hyper Threading is enabled this will be double the number of
// physical cores
int numCores = Runtime.getRuntime().availableProcessors();
// Create a thread pool of size equal to numCores
ExecutorService threadPool = Executors.newFixedThreadPool(numCores);
// Initialize all of the Tasks and add them to the thread pool
for (int i = 0; i < numCores; i++) {
Runnable task = new WellFormedStringRunnable(sharedQueue);
threadPool.execute(task);
}
// Do not allow any more tasks to be added and wait for all tasks to be
// completed before shutting down the executor
threadPool.shutdown();
// Read form STDIN and add each line to the shared queue
try (BufferedReader br = new BufferedReader(new InputStreamReader(System.in))) {
// The current line
String input;
// Continue processing until a null character has been reached
while ((input = br.readLine()) != null) {
// Add the tuple (line number, string) to the shared queue
try {
sharedQueue.put(input);
} catch (InterruptedException e) {
System.err.println("Error accessing shared queue: "
+ e.getMessage());
threadPool.shutdownNow();
System.exit(1);
}
}
} catch (IOException e) {
System.err.println("Error reading from STDIN: " + e.getMessage());
System.exit(1);
}
// Allow all threads to complete
try {
threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
} catch (InterruptedException e) {
// If the shared queue throws an exception, display the error and
// shutdown all running tasks
System.err.println("Error while waiting for threads to terminate: "
+ e.getMessage());
threadPool.shutdownNow();
System.exit(1);
}
}
线程代码:
public class RunnableThread implements Runnable {
/** A blocking queue used to retrieve strings */
private final BlockingQueue<String> sharedQueue;
public RunnableThread(BlockingQueue<String> sharedQueue) {
this.sharedQueue = sharedQueue;
}
@Override
public void run() {
// Used to hold a value from the shared queue
String currValue = null;
// Continue to process strings while the thread is not interrupted and
while (!Thread.currentThread().isInterrupted()) {
try {
// Get a string from the shared queue
currValue = this.sharedQueue.take();
// Process Strings
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
}
}
什么是你真正要完成的,在这里? – 2014-09-30 18:53:22
...因为强行杀死另一个线程几乎总是一个坏主意。 – 2014-09-30 18:55:01