Java में Async File I/O

// Define the class Main
public class Main {
	// Program entry point: the JVM starts running here
	public static void main(String[] args) {
		// Print a line to the console
		System.out.println("Async I/O starts an operation and continues, notified only on completion");
	}
}

Login to try C/C++/Java/PHP code in the editor

// Import java.nio.channels.AsynchronousFileChannel so it can be used by its short name
import java.nio.channels.AsynchronousFileChannel;
// Import java.nio.file.* so it can be used by its short name
import java.nio.file.*;
// Define the class Main
public class Main {
	// Program entry point: the JVM starts running here
	public static void main(String[] args) throws Exception {
		Path file = Files.createTempFile("demo", ".txt");
		AsynchronousFileChannel channel = AsynchronousFileChannel.open(file, StandardOpenOption.READ);
		// Print a line to the console
		System.out.println("Opened: " + channel.isOpen());
		channel.close();
		Files.delete(file);
	}
}

Login to try C/C++/Java/PHP code in the editor

import java.nio.channels.AsynchronousFileChannel;
import java.nio.file.*;
import java.nio.ByteBuffer;
import java.util.concurrent.Future;
public class Main {
	public static void main(String[] args) throws Exception {
		Path file = Files.createTempFile("demo", ".txt");
		Files.writeString(file, "hello");
		AsynchronousFileChannel channel = AsynchronousFileChannel.open(file, StandardOpenOption.READ);
		ByteBuffer buffer = ByteBuffer.allocate(5);
		Future<Integer> future = channel.read(buffer, 0); // returns immediately
		future.get(); // blocks only here, when the result is needed
		System.out.println(new String(buffer.array()));
		channel.close();
		Files.delete(file);
	}
}

Login to try C/C++/Java/PHP code in the editor

// Import java.nio.channels.* so it can be used by its short name
import java.nio.channels.*;
// Import java.nio.file.* so it can be used by its short name
import java.nio.file.*;
import java.nio.ByteBuffer;
// Define the class Main
public class Main {
	// Program entry point: the JVM starts running here
	public static void main(String[] args) throws Exception {
		Path file = Files.createTempFile("demo", ".txt");
		Files.writeString(file, "data");
		AsynchronousFileChannel channel = AsynchronousFileChannel.open(file, StandardOpenOption.READ);
		ByteBuffer buffer = ByteBuffer.allocate(4);
		channel.read(buffer, 0, null, new CompletionHandler<Integer, Void>() {
			public void completed(Integer result, Void attachment) {
				// Print a line to the console
				System.out.println("Read complete: " + new String(buffer.array()));
			}
			public void failed(Throwable exc, Void attachment) {
				// Print a line to the console
				System.out.println("Failed: " + exc.getMessage());
			}
		});
		Thread.sleep(100);
		channel.close();
		Files.delete(file);
	}
}

Login to try C/C++/Java/PHP code in the editor

import java.nio.channels.AsynchronousFileChannel;
import java.nio.file.*;
import java.nio.ByteBuffer;
public class Main {
	public static void main(String[] args) throws Exception {
		Path file = Files.createTempFile("demo", ".txt");
		AsynchronousFileChannel channel = AsynchronousFileChannel.open(file, StandardOpenOption.WRITE);
		ByteBuffer buffer = ByteBuffer.wrap("async write".getBytes());
		channel.write(buffer, 0).get(); // complete once actually written
		channel.close();
		System.out.println(Files.readString(file));
		Files.delete(file);
	}
}

Login to try C/C++/Java/PHP code in the editor