多线程练习题
编写程序实现,子线程循环3次,接着主线程循环5次,接着再子线程循环3次,主线程循环5次,如此反复,循环3次
第一种实现方式：使用synchronized关键字
package com.aaa.test;
public class Test1 {
private boolean flag=false;
// 主线程要实现的功能
public synchronized void mainFunction(){
while (!flag){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
for (int i=0;i<5;i++){
System.out.println("mainFunction,主线程循环"+i+"次");
}
this.notify();
flag=false;
}
// 子线程要实现的功能
public synchronized void subFunction(){
while (flag){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
for (int i=0;i<3;i++){
System.out.println("subFunction,子线程循环"+i+"次");
}
this.notify();
flag=true;
}
public static void main(String[] args) {
final Test1 t= new Test1();
// 子线程循环三次
new Thread(new Runnable() {
public void run() {
for (int i=0;i<3;i++){
t.subFunction();
System.out.println("======");
}
}
}).start();
// 主线程循环三次
for (int i=0;i<3;i++){
t.mainFunction();
System.out.println("======");
}
}
}
第二种实现方式：使用 lock 锁和 Condition 接口
package com.aaa.test;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Test2 {
private boolean flag = false;
Lock lock = new ReentrantLock();
Condition con = lock.newCondition();
// 主线程要实现的功能
public void mainFunction(){
System.out.println("1.主线程开始"+" -- flag="+flag);
lock.lock();
try{
while(!flag){
try {
System.out.println("2.主线程等待"+" -- flag="+flag);
con.await();
// 使当前线程加入 await() 等待队列中，并释放当锁，当其他线程调用signal()会重新请求锁。与Object.wait()类似。
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("7.主线程开始循环5次"+" -- flag="+flag);
for(int i=0;i<5;i++){
System.out.println("mainFunction"+i+" -- flag="+flag);
}
flag = false;
System.out.println("8.唤醒子线程"+" -- flag="+flag);
con.signal();
// 唤醒一个在 await()等待队列中的线程。与Object.notify()相似
}finally{
lock.unlock();
}
}
// 子线程要实现的功能
public void subFunction(){
System.out.println("3.子线程开始"+" -- flag="+flag);
lock.lock();
try{
while(flag){
try {
System.out.println("6.子线程等待"+" -- flag="+flag);
con.await(); // 使当前线程加入 await() 等待队列中，并释放当锁，当其他线程调用signal()会重新请求锁。与Object.wait()类似。
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("4.子线程开始循环3次"+" -- flag="+flag);
for(int i=0;i<3;i++){
System.out.println("subFunction"+i+" -- flag="+flag);
}
flag = true;
System.out.println("5.唤醒主线程"+" -- flag="+flag);
con.signal(); // 唤醒一个在 await()等待队列中的线程。与Object.notify()相似
}finally{
lock.unlock();
}
}
public static void main(String[] args) {
final Test2 t= new Test2();
// 子线程循环三次
new Thread(new Runnable() {
public void run() {
for (int i=0;i<3;i++){
t.subFunction();
System.out.println("======");
}
}
}).start();
// 主线程循环三次
for (int i=0;i<3;i++){
t.mainFunction();
System.out.println("======");
}
}
}
模拟多个人通过一个山洞的模拟，这个山洞每次只能通过一个人，每个人通过山洞的时间为5秒，随机生成10个人，同时准备过此山洞，显示以下每次通过山洞的人的姓名。
package com.aaa.test;
import java.util.LinkedHashSet;
import java.util.Set;
public class Test3 implements Runnable{
private static int deng=0;
@Override
public void run() {
deng= deng+50;
try
{
Thread.sleep(deng);
} catch (InterruptedException e)
{
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()
+" 过山洞");
}
public static void main(String[] args) {
String ary[] ={"赵","钱","孙","李","周","吴","郑","王","冯","陈"};
Test3 gsd = new Test3();
Set<Integer> set=new LinkedHashSet<Integer>();
while(true){
if(set.size() == 10){
break;
}
//乱序排列（随机）
int a=(int) (Math.random()*10);
set.add(a);
}
for(int b:set){
Thread th = new Thread(gsd, ary[b]);
th.start();
}
}
}