能不能写一个run方法让两个线程交替运行 - 黑马程序员技术交流社区

import java.util.Random;
/*练习：声明一个共享数组，起两个线程，两个线程分别隔一段时间(可以写一个随机数)，
* 给数组中添加数据，每一个线程为数组添加3个数据即可。
*/
public class Test11 {
public static void main(String[] args) {
int [] arr = new int [6];
ShareArray shareArray = new ShareArray(arr);
Thread thread1 = new Thread(new AddValue1(shareArray));
Thread thread2 = new Thread(new AddValue2(shareArray));
thread1.start();
thread2.start();
}
}
//定义多线程操作的资源
class ShareArray {
int[] arr;
int i = 0;
boolean flag = false;
ShareArray(int[] arr) {
this.arr = arr;
}
//给数组添加数据
public void setValue(int x) {
arr[i] = x;
System.out.println(Thread.currentThread().getName() + "添加了--->"
+ arr[i]);
i++;
}
}
//线程对资源的操作
class AddValue1 implements Runnable {
ShareArray shareArray;
AddValue1(ShareArray shareArray){
this.shareArray = shareArray;
}
@Override
public void run() {
// TODO Auto-generated method stub
for (int i = 0; i < 3; i++) {//让线程给数组循环添加数据
synchronized (shareArray) {//给操作共享数据的语句加上同步，用资源类对象作为锁
if (shareArray.flag){
try {
shareArray.wait();
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
shareArray.setValue(new Random().nextInt(10));
shareArray.flag = true;
shareArray.notify();
}
}
}
}
class AddValue2 implements Runnable {
ShareArray shareArray;
AddValue2(ShareArray shareArray){
this.shareArray = shareArray;
}
@Override
public void run() {
// TODO Auto-generated method stub
for (int i = 0; i < 3; i++) {
synchronized (shareArray) {
if (!shareArray.flag){
try {
shareArray.wait();
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
shareArray.setValue(new Random().nextInt(10));
shareArray.flag = false;
shareArray.notify();
}
}
}
}

复制代码

public class Gongxiang
{
public int index=0;//在主类中设置索引并初始化以便其他类引用
public static void main(String[] args)
{
int[] share=new int[6];//设置想要存入入局的数组
Gongxiang gg=new Gongxiang();//创建一个主函数对象以得到共享的索引
//创建线程并启动
Thread t1=new Thread(new WriteArr(share,gg),"1号线程");
Thread t2=new Thread(new WriteArr(share,gg),"2号线程");
t1.start();
t2.start();
//线程执行完后才能让主函数遍历数组
try
{
t1.join();
t2.join();
}
catch(Exception e)
{
e.printStackTrace();
}
//遍历存入数据的数组
for(int i:share)
System.out.println(i);
}
}
class WriteArr implements Runnable
{
private int[] share;
private Gongxiang gg;
public WriteArr(int[] share,Gongxiang gg)//初始化构造函数，获取数组与主类对象
{
this.share=share;
this.gg=gg;
}
public void run()
{
for(int i=0;i<3;i++)//每个线程存3个数据
{
try
{
Thread.sleep((int)(Math.random()*10));//每次睡眠一段时间再存
}
catch(Exception e)
{
e.printStackTrace();
}
synchronized(share)//同步加锁防止索引错误
{
this.share[gg.index++] = (int)(Math.random()*10);//存入随机数
System.out.println(Thread.currentThread().getName()+"存入了"+share[gg.index-1]);//输出存入信息
}
}
}
}

复制代码