Question

java 实现两个线程,一个打印奇数,一个打印偶数,这两个线程并发执行

java 实现两个线程,一个打印奇数,一个打印偶数,这两个线程并发执行

Answer 1

同时启动两个线程，让线程分别打印奇数和偶数。示例定义两个线程分别打印1000以内的奇偶数，同时为了看到并发效果，每个线程打印完一个数字后都会进行暂停：

	
	public static void main(String[] args) {
		final int count = 1000;
		new Thread(){
			public void run() {
				for(int i = 1; i <= count ;i=i+2) {
					// 奇数，起始值为1，增长步长为2
					try {
						System.out.println("奇数线程：\t" + i);
						// 暂停0.5秒
						sleep(1);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			};
		}.start();
		new Thread(){
			public void run() {
				for(int i = 0; i <= count ;i=i+2) {
					// 偶数，起始值为0，增长步长为2
					try {
						System.out.println("偶数线程：\t" + i);
						// 暂停0.5秒
						sleep(1);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			};
		}.start();
	}

输出结果：

偶数线程：	0
奇数线程：	1
偶数线程：	2
奇数线程：	3
偶数线程：	4
奇数线程：	5
偶数线程：	6
奇数线程：	7
偶数线程：	8
奇数线程：	9
偶数线程：	10
......
奇数线程：	991
偶数线程：	986
奇数线程：	993
偶数线程：	988
奇数线程：	995
偶数线程：	990
奇数线程：	997
偶数线程：	992
奇数线程：	999
偶数线程：	994
偶数线程：	996
偶数线程：	998
偶数线程：	1000

Answer 2

package test;
public class Test33{
private static int state = 1;
private static int num1 = 1;
private static int num2 = 2;

public static void main(String[] args) {
final Test33 t = new Test33();
new Thread(new Runnable() {
@Override
public void run() {
while(num1<100){
//两个线程都用t对象作为锁，保证每个交替期间只有一个线程在打印
synchronized (t) {
// 如果state!=1, 说明此时尚未轮到线程1打印, 线程1将调用t的wait()方法, 直到下次被唤醒
if(state!=1){
try {
t.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 当state=1时, 轮到线程1打印5次数字
for(int j=0; j<1; j++){
System.out.println(num1);
num1 += 2;
}
// 线程1打印完成后, 将state赋值为2, 表示接下来将轮到线程2打印
state = 2;
// notifyAll()方法唤醒在t上wait的线程2, 同时线程1将退出同步代码块, 释放t锁
t.notifyAll();
}
}
}
}).start();

new Thread(new Runnable() {
@Override
public void run() {
while(num2<100){
synchronized (t) {
if(state!=2){
try {
t.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
for(int j=0; j<1; j++){
System.out.println(num2);
num2 += 2;
}
state = 1;
t.notifyAll();
}
}
}
}).start();
}

}

Answer 3

package test;
public class Test33{
private static int state = 1;
private static int num1 = 1;
private static int num2 = 2;

public static void main(String[] args) {
final Test33 t = new Test33();
new Thread(new Runnable() {
@Override
public void run() {
while(num1<100){
//两个线程都用t对象作为锁，保证每个交替期间只有一个线程在打印
synchronized (t) {
// 如果state!=1, 说明此时尚未轮到线程1打印, 线程1将调用t的wait()方法, 直到下次被唤醒
if(state!=1){
try {
t.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 当state=1时, 轮到线程1打印5次数字
for(int j=0; j<1; j++){
System.out.println(num1);
num1 += 2;
}
// 线程1打印完成后, 将state赋值为2, 表示接下来将轮到线程2打印
state = 2;
// notifyAll()方法唤醒在t上wait的线程2, 同时线程1将退出同步代码块, 释放t锁
t.notifyAll();
}
}
}
}).start();

new Thread(new Runnable() {
@Override
public void run() {
while(num2<100){
synchronized (t) {
if(state!=2){
try {
t.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
for(int j=0; j<1; j++){
System.out.println(num2);
num2 += 2;
}
state = 1;
t.notifyAll();
}
}
}
}).start();
}

}