方法一: public class threadDemo { public static void main(String[] args) { final Object o=new Object(); final char[] nums="1234567".toCharArray(); final char[] chars="ABCDEFG".toCharArray(); new Thread(new Runnable() { @SneakyThrows @O
方法一:
public class threadDemo {public static void main(String[] args) {
final Object o=new Object();
final char[] nums="1234567".toCharArray();
final char[] chars="ABCDEFG".toCharArray();
new Thread(new Runnable() {
@SneakyThrows
@Override
public void run() {
synchronized (o){
for(char num:nums){
System.out.println(num);
o.notify();
o.wait();
}
o.notify();
}
}
}).start();
new Thread(new Runnable() {
@SneakyThrows
@Override
public void run() {
synchronized (o){
for(char ch:chars){
System.out.println(ch);
o.notify();
o.wait();
}
o.notify();
}
}
}).start();
}
}
方法二:
public class threadDemo {static Thread t1=null,t2=null;
public static void main(String[] args) {
final char[] nums="1234567".toCharArray();
final char[] chars="ABCDEFG".toCharArray();
t1=new Thread(new Runnable() {
@Override
public void run() {
for(char num:nums){
System.out.println(num);
LockSupport.unpark(t2);
LockSupport.park();
}
}
});
t2=new Thread(new Runnable() {
@Override
public void run() {
for(char num:chars){
LockSupport.park();//挂起
System.out.println(num);
LockSupport.unpark(t1);//叫醒
}
}
});
t1.start();
t2.start();
}
}
方法三:
public class threadDemo {public static void main(String[] args) {
final char[] nums="1234567".toCharArray();
final char[] chars="ABCDEFG".toCharArray();
final Lock reentrantLock = new ReentrantLock();
final Condition condition = reentrantLock.newCondition();
new Thread(new Runnable() {
@Override
public void run() {
reentrantLock.lock();//相当synchronized
for(char num:nums){
System.out.println(num);
condition.signal();//相当于notify
try {
condition.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
condition.signal();
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
reentrantLock.lock();
for(char num:chars){
System.out.println(num);
try {
condition.signal();
condition.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
condition.signal();
}
}).start();
}
}