Asynchronous File I/O in Java

Asynchronous File I/O in Java is a framework I created because I got tired of waiting for JSR 203 and IBM's AIO4J doesn't have support for asynchronous file access with Linux. The framework is still in very early development. It currently only supports Linux. The API is in flux. And the framework hasn't received a great deal of testing. I expect all this to change for the better in the near future. I've make the project available so that others can help with testing and hopefully there are others out there who would like to contribute to the project. I will try to post examples and additional documentation here as the framework progresses.

The source code for the project can be found in my subversion sandbox as part of the Apache Mina project https://svn.apache.org/repos/asf/mina/sandbox/mheath/aioj.

To build the project use Maven 2 and run "mvn package". This will produce two artifacts. A Java .jar file containing the Java classes and libaioj.so which contains the the native binaries that make the POSIX AIO calls to do asynchronous file IO in Java.

Example

Below is a simple example of how to use Asynchronous File I/O in Java.

import java.io.FileInputStream;
import java.nio.ByteBuffer;

import org.apache.aio.AioFutureListener;
import org.apache.aio.AioFutureReadWrite;
import org.apache.aio.AsynchronousFileChannel;

public class AIOTest {

	public static void main(String[] args) throws Exception {
		FileInputStream in = new FileInputStream("/etc/passwd");

		AsynchronousFileChannel achannel = new AsynchronousFileChannel(in.getFD());
		
		AioFutureListener<AioFutureReadWrite> listener = new AioFutureListener<AioFutureReadWrite>() {
					public void onCompletion(AioFutureReadWrite ioFuture) {
						System.out.println("In callback");
						byte[] data = new byte[ioFuture.getBuffer().limit() - ioFuture.getBuffer().position()];
						ioFuture.getBuffer().get(data);
						System.out.println("  Buffer contains: " + new String(data));
					}
				};
		ByteBuffer buffer = ByteBuffer.allocateDirect(4096);
		AioFutureReadWrite future = achannel.read(buffer, 0);
		future.addListener(listener);
		future.join();
	}
		
}