java A线程向C目录写文件 B线程从C目录移动文件

java A线程向C目录写文件，B线程从C目录移动文件，如何防止B线程移动A线程正在写入的文件，或者当遇到特殊情况，比如断电，如何保证文件的完整？

package thread;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

public class TestFileTrans {
    public static void main(String[] args) {
        String inPath = "D:" + File.separator + "testFile" + File.separator + "inPath";
        File inPathFile = new File(inPath);
        String outPath = "D:" + File.separator + "testFile" + File.separator  + "outPath";
        File outPathFile = new File(outPath);
        if (!inPathFile.exists()) {
            inPathFile.mkdirs();
        }
        if (!outPathFile.exists()) {
            outPathFile.mkdirs();
        }
        
        // A 线程以100毫秒的速度写入文件
        new Thread(new WriteFile(inPath, 100), "w:").start();
        // B 线程以1毫秒的速度移动文件
        new Thread(new removeFile(inPath, outPath, 1), "m:").start();
    }
}

class WriteFile implements Runnable {
    String inPath;
    int time;
    WriteFile(String path, int time) {
        this.inPath = path;
        this.time = time;
    }

    @Override
    public void run() {
        while (true) {
            try {
                // 需要移动的是一个10.9 MB (11,486,712 字节) 的文件
                File testFile = new File("D:/soft/FoxitReader431_chs_Setup.exe");
                FileInputStream is = new FileInputStream(testFile);
                byte[] b = new byte[1024 * 10];
                int temp;
                
                File file = new File(inPath + File.separator  + System.nanoTime() + ".txt");
                FileOutputStream os = new FileOutputStream(file);
                while ((temp = is.read(b)) != -1) {
                    os.write(b, 0, temp);
                }
                os.flush();
                os.close();
                is.close();
                
                System.out.println(Thread.currentThread().getName() + file.getName());
                Thread.sleep(time);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

class removeFile implements Runnable {
    String inPath;
    String outPath;
    int time;
    removeFile(String inPath, String outPath, int time) {
        this.inPath = inPath;
        this.outPath = outPath;
        this.time = time;
    }

    @Override
    public void run() {
        while (true) {
            try {
                File[] files = new File(inPath).listFiles();
                Pattern pattern = Pattern.compile("^\\d{14}.txt$");
                for (File file : files) {
                    Matcher matcher = pattern.matcher(file.getName());
                    if (matcher.matches()) {

                        File outFile = new File(outPath, file.getName());
                        FileInputStream is = new FileInputStream(file);
                        FileOutputStream os = new FileOutputStream(outFile);
                        byte[] b = new byte[1024 * 10];
                        int temp;
                        while ((temp = is.read(b)) != -1) {
                            os.write(b, 0, temp);
                        }
                        os.flush();
                        os.close();
                        is.close();
                        
                        file.delete();
                        System.out.println(Thread.currentThread().getName() + outFile.getName());
                    }
                }
                Thread.sleep(time);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}