Java多文件读写操作实例，理解同步与异步

原创た入场券 2024-12-04 20:33 0阅读 0赞

在Java中，我们可以使用多个文件进行读写操作。下面我们将通过一个实例来理解同步与异步的概念。

1. **同步读写**：
   这种方式是线程安全的，当一个线程正在访问文件时，其他线程不能访问该文件，否则可能会导致数据不一致。

2. **异步读写**：
   这种方式允许一个线程在等待某个操作完成（如文件读写）的同时继续执行其他的任务。当文件操作完成后，会有一个回调方法来处理结果。

下面是一个简单的Java多文件读写的同步和异步示例：

- 同步读写：

```java
import java.io.*;

public class SyncReadWrite {
    private File file1 = new File("file1.txt");
    private File file2 = new File("file2.txt");

public void syncReadWrite() throws IOException {
        // 同步读写
        BufferedWriter writer1 = new BufferedWriter(new FileWriter(file1)));
        BufferedWriter writer2 = new BufferedWriter(new FileWriter(file2)));

try {
            // 写入数据
            writer1.write("Data for file1");
            writer2.write("Data for file2");

// 关闭写入器，确保文件已正确写入
            writer1.close();
            writer2.close();

System.out.println("Files written successfully!");
        } finally {
            // 文件读写完成后，关闭所有资源
            writer1.close();
            writer2.close();
            file1.delete(); // 删除临时文件
            file2.delete(); // 删除临时文件
        }
    }

public static void main(String[] args) throws IOException {
        new SyncReadWrite().syncReadWrite();
    }
}
```

- 异步读写（使用`ExecutorService`）：

```java
import java.io.*;
import java.util.concurrent.*;

public class AsyncReadWrite {
    private File file1 = new File("file1.txt");
    private File file2 = new File("file2.txt");

public void asyncReadWrite(ExecutorService executor) throws IOException {
        // 异步读写
        BufferedWriter writer1 = new BufferedWriter(new FileWriter(file1)));
        BufferedWriter writer2 = new BufferedWriter(new FileWriter(file2)));

// 提交任务到线程池
        Future<Void> future1 = executor.submit(() -> writeDataAndClose(writer1), "file1.txt", writer1));
        Future<Void> future2 = executor.submit(() -> writeDataAndClose(writer2), "file2.txt", writer2));

// 等待所有任务完成
        try {
            future1.get(); // 获取"文件1.txt"的写入结果
            future2.get(); // 获取"文件2.txt"的写入结果
        } catch (InterruptedException | ExecutionException e) {
            System.err.println("Error occurred during async read/write: " + e.getMessage());
            e.printStackTrace();
        }

// 关闭所有资源
        writer1.close();
        writer2.close();

System.out.println("Files written asynchronously!");
    }

private void writeDataAndClose(BufferedWriter writer, String fileName, BufferedWriter closeWriter) throws IOException {
        // 写入数据
        writer.write("Data for " + fileName);

// 关闭写入器，确保文件已正确写入
        writer.close();
    }

public static void main(String[] args) throws InterruptedException, ExecutionException, IOException {
        ExecutorService executor = Executors.newFixedThreadPool(2); // 创建一个固定大小的线程池

new AsyncReadWrite().asyncReadWrite(executor);

// 关闭线程池
        executor.shutdown();
    }
}
```

在上述示例中，我们展示了如何使用同步和异步方式读写多文件。如果你想要理解更多的细节或者有其他问题，欢迎继续提问！