我将创建两个java线程（一个线程用于乘法，另一个线程用于加法）
我必须得到如下输出：
这是我的密码。没有错误。它以PlusThread开始并打印第一行。然后它将释放锁。之后，MultiplyThread开始运行。它将打印所有行，而不是通知PlusThread。
public class TestThread {
public static void main(String[] args) {
// TODO Auto-generated method stub
Object lock = new Object();
PlusThread pT = new PlusThread(lock, 2, 10);
pT.start();
MultiplyThread mT = new MultiplyThread(lock, 2, 10);
mT.start();
}
}
class PlusThread extends Thread {
Object lock;
int start, range;
public PlusThread(Object lock, int start, int range) {
super();
this.lock = lock;
this.start = start;
this.range = range;
}
@Override
public void run() {
synchronized (this) {
for (int i = start; i <= range; ++i) {
System.out.println(i + " + " + i + " = " + (i + i));
try {
this.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
class MultiplyThread extends Thread {
Object lock;
int start, range;
public MultiplyThread(Object lock, int start, int range) {
this.lock = lock;
this.start = start;
this.range = range;
}
@Override
public void run() {
synchronized (this) {
for (int j = start; j <= range; ++j) {
System.out.println(j + " * " + j + " = " + (j * j));
this.notify();
}
}
}
}
这是我的输出：
共有2个答案
这会管用的
static class PlusThread extends Thread {
final Object lock;
int start, range;
public PlusThread(Object lock, int start, int range) {
super();
this.lock = lock;
this.start = start;
this.range = range;
}
@Override
public void run() {
synchronized (lock) {
for (int i = start; i <= range; ++i) {
try {
lock.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(i + " + " + i + " = " + (i + i));
lock.notify();
}
}
}
}
static class MultiplyThread extends Thread {
final Object lock;
int start, range;
public MultiplyThread(Object lock, int start, int range) {
this.lock = lock;
this.start = start;
this.range = range;
}
@Override
public void run() {
synchronized (lock) {
for (int j = start; j <= range; ++j) {
System.out.println(j + " * " + j + " = " + (j * j));
lock.notify();
try {
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
try this:
public class TestThread {
static Object lock = new Object();
public static void main(String[] args) {
// TODO Auto-generated method stub
PlusThread pT = new PlusThread(lock, 2, 10);
pT.start();
MultiplyThread mT = new MultiplyThread(lock, 2, 10);
mT.start();
}
}
class PlusThread extends Thread {
Object lock;
int start, range;
public PlusThread(Object lock, int start, int range) {
super();
this.lock = lock;
this.start = start;
this.range = range;
}
@Override
public void run() {
synchronized (lock) {
for (int i = start; i <= range; ++i) {
System.out.println(i + " + " + i + " = " + (i + i));
try {
lock.notify();
lock.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
class MultiplyThread extends Thread {
Object lock;
int start, range;
public MultiplyThread(Object lock, int start, int range) {
this.lock = lock;
this.start = start;
this.range = range;
}
@Override
public void run() {
synchronized (lock) {
for (int j = start; j <= range; ++j) {
System.out.println(j + " * " + j + " = " + (j * j));
lock.notify();
try {
lock.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
-
我如何启动两个线程，其中thread1首先执行，thread2在thread1结束时启动，而主方法线程可以在不锁定其他两个线程的情况下继续工作？ 我尝试了join()，但是它需要从线程调用，线程必须等待另一个线程，没有办法执行类似thread2.join(thread1)的操作；因此，如果我在main（）中调用join，我将有效地停止主线程的执行，而不仅仅是Thread2的执行。 #编辑：为什么我
-
问题内容： 我是线程新手。我想创建一些与主线程分开工作的简单函数。但这似乎不起作用。我只想创建一个新线程，并在那里独立于主线程发生的事情做一些事情。这段代码看起来很怪异，但到目前为止，我对线程的了解还很少。你能解释一下这是怎么回事吗？ 问题答案： 您正在线程方法中调用该方法。但是只有在线程已经启动时才调用该方法。改为这样做：
-
问题内容： 我在Java中的线程上有些挣扎，我有三个线程- 线程1，线程2和线程3。那些启动时正在执行某些任务，我想通过thread1停止这两个线程。我将thread1放在，然后停止两个线程，但是两个线程的进程仍在运行。你有什么想法吗？ 问题答案： 您如何试图阻止他们？？警告此方法已弃用。 而是考虑对线程1使用某种标志来与线程2和3通信，它们应该停止。实际上，您可能会使用interrupts。 下
-
问题内容： 我正在尝试实现2个线程。我的测试代码试图使用两个线程来执行以下方案： 线程B等待条件 线程A打印“ Hello”五次 线程A通知线程B 线程A等待 线程B打印“再见” 线程B向线程A发出信号 循环开始（x5） 到目前为止，代码将打印“ Hello”五次，然后卡住。从我看过的示例中，我似乎走对了，“锁定互斥锁，等待，由其他线程发出信号，解锁互斥锁，执行操作，循环” 测试代码： 朝着正确方
-
我正在阅读这篇文章，关于从一个线程中断另一个线程的建议是 “”“如果正确实施，以下几种方法应该可以奏效。 您可以让两个线程定期检查一些常见的标志变量（例如，将其称为stopNow），并安排两个线程在完成时进行设置。（标志变量需要是volatile…或正确同步的。） 您可以让两个线程定期调用线程。isInterrupted（）方法，查看它是否已被中断。然后每个线程都需要调用线程。完成后，在另一个上中
-
问题 你创建一个工作者线程池，用来响应客户端请求或执行其他的工作。 解决方案 concurrent.futures 函数库有一个 ThreadPoolExecutor 类可以被用来完成这个任务。 下面是一个简单的TCP服务器，使用了一个线程池来响应客户端： from socket import AF_INET, SOCK_STREAM, socket from concurrent.futures