Java IO怎样实现多线程并发读写

在Java中，可以使用多线程来实现对文件的并发读写。这里有一个简单的示例，展示了如何使用两个线程（一个用于读取，一个用于写入）来实现对文件的并发操作。

首先，创建一个名为FileHandler的类，该类将负责处理文件的读写操作：

import java.io.*;

public class FileHandler {
    private String filePath;

    public FileHandler(String filePath) {
        this.filePath = filePath;
    }

    public synchronized void writeToFile(String content) throws IOException {
        try (BufferedWriter writer = new BufferedWriter(new FileWriter(filePath, true))) {
            writer.write(content);
            writer.newLine();
        }
    }

    public synchronized String readFromFile() throws IOException {
        StringBuilder content = new StringBuilder();
        try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) {
            String line;
            while ((line = reader.readLine()) != null) {
                content.append(line).append("\n");
            }
        }
        return content.toString();
    }
}

在这个类中，我们使用了synchronized关键字来确保在同一时间只有一个线程可以访问writeToFile和readFromFile方法。这可以防止在读写过程中发生数据不一致的问题。

接下来，创建一个名为FileHandlerThread的抽象类，该类将作为读写线程的基类：

public abstract class FileHandlerThread extends Thread {
    protected FileHandler fileHandler;

    public FileHandlerThread(FileHandler fileHandler) {
        this.fileHandler = fileHandler;
    }

    public abstract void run();
}

现在，可以创建两个子类，一个用于读取文件，另一个用于写入文件：

public class ReadThread extends FileHandlerThread {
    private String output;

    public ReadThread(FileHandler fileHandler, String output) {
        super(fileHandler);
        this.output = output;
    }

    @Override
    public void run() {
        try {
            String content = fileHandler.readFromFile();
            System.out.println("Read from file: " + content);
            output = content;
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

public class WriteThread extends FileHandlerThread {
    private String content;

    public WriteThread(FileHandler fileHandler, String content) {
        super(fileHandler);
        this.content = content;
    }

    @Override
    public void run() {
        try {
            fileHandler.writeToFile(content);
            System.out.println("Write to file: " + content);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

最后，在主类中创建FileHandler实例以及读写线程实例，并启动这些线程：

public class Main {
    public static void main(String[] args) {
        FileHandler fileHandler = new FileHandler("test.txt");

        ReadThread readThread = new ReadThread(fileHandler, "");
        WriteThread writeThread = new WriteThread(fileHandler, "Hello, World!");

        readThread.start();
        writeThread.start();

        try {
            readThread.join();
            writeThread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("Read from file after writing: " + readThread.output);
    }
}

这个示例中，我们首先创建了一个FileHandler实例，然后创建了一个读取线程和一个写入线程。接着，我们启动这两个线程，并等待它们完成。最后，我们打印出在写入操作之后从文件中读取的内容。

这个示例展示了如何使用多线程实现对文件的并发读写。你可以根据需要扩展这个示例，例如添加更多的读取和写入线程，或者实现其他复杂的文件操作。