文件读写线程-交替执行wait(10)-线程不写在同一个类中,多线程

package cn.thread.fen;

import java.io.IOException;

public class FileReadThread extends Thread{
 private CommThreadArgs args;
 public FileReadThread(CommThreadArgs args){
  this.args=args;
 }

 public void run() {
  try {
   synchronized(this) {
    while (args.getLen()!=-1) { //读完整个文件,len=-1
     if (args.getLen() != 0) {
      wait(10);
     }
     else{
      int length = args.getIs().read(args.getBuf(), 0, args.getBuf().length);
      args.setLen(length);
      System.out.println("----------"+length);
      notify();
     }
    }
   }
  } catch (IOException e) {
   e.printStackTrace();
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
 }
}

2.
package cn.thread.fen;

import java.io.IOException;

public class FileWriteThread extends Thread {
 private CommThreadArgs args;
 public FileWriteThread(CommThreadArgs args){
  this.args=args;
 }
 
 public void run() {
  synchronized(this){
  while(true){ 
   if(args.getLen()==0){
    try {
     wait(10);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
   }
   else{
    System.out.println("*********"+args.getLen());
    if(args.getLen()==-1){ //读线程结束，写线程也结束
     try{
      args.getIs().close();
      args.getOs().close();
     } catch (IOException e) {
      e.printStackTrace();
     }
     break;
    }
    try {
     args.getOs().write(args.getBuf(), 0, args.getLen());
//     os.flush();
    } catch (IOException e) {
     e.printStackTrace();
    }

    args.setLen(0);
    notify();
   }
  }
  }
 }
}

3.
package cn.thread.fen;

import java.io.FileInputStream;
import java.io.FileOutputStream;

//线程公用的同一个实例,共用参数
public class CommThreadArgs {
 private FileInputStream is;
 private volatile byte[] buf;   //文件读写公用的缓存数据
 private volatile int len = 0;//读取的字符长度，公用
 private FileOutputStream os;

 /**
  *
  */
 public static void main(String[] args) {

  
 }

 public synchronized FileInputStream getIs() {
  return is;
 }

 public void setIs(FileInputStream is) {
  this.is = is;
 }

 public synchronized byte[] getBuf() {
  return buf;
 }

 public synchronized int getLen() {
  return len;
 }

 public synchronized void setLen(int len) {
  this.len = len;
 }

 public void setOs(FileOutputStream os) {
  this.os = os;
 }

 public synchronized FileOutputStream getOs() {
  return os;
 }

 public void setBuf(byte[] buf) {
  this.buf = buf;
 }
 
}

4.测试文件读写线程：
package cn.thread.fen;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;

public class TestThread {

 /**
  *
  */
 public static void main(String[] args) throws Exception {

  CommThreadArgs ar=new CommThreadArgs();
  File file = new File("E:\\Log\\bc2.txt");
  int i=(int)(Math.random()*100);
  File of = new File("E:\\Log\\"+i+".txt");
  
  FileReadThread r = new FileReadThread(ar);
  ar.setIs(new FileInputStream(file));

  byte[] buf = new byte[512];
  ar.setBuf(buf);
  FileWriteThread w = new FileWriteThread(ar);
  ar.setOs(new FileOutputStream(of));

  r.start();  //起动读线程
  w.start(); //起动写线程
  
  Thread.currentThread().sleep(2000);
  
  CommThreadArgs ar2=new CommThreadArgs();
  File file2 = new File("E:\\Log\\814.txt");
  int i2=(int)(Math.random()*100);
  File of2 = new File("E:\\Log\\"+i2+".txt");
  
  FileReadThread r2 = new FileReadThread(ar2);
  ar2.setIs(new FileInputStream(file2));

  byte[] buf2 = new byte[512];
  ar2.setBuf(buf2);
  FileWriteThread w2 = new FileWriteThread(ar2);
  ar2.setOs(new FileOutputStream(of2));

  r2.start();  //起动读线程
  w2.start(); //起动写线程
 }

}