import java.io.IOException;

import java.nio.channels.SelectionKey;

import java.nio.channels.Selector;

import java.nio.channels.spi.AbstractSelectableChannel;

import java.nio.channels.spi.AbstractSelector;

import java.util.Set;

/**

* NativeTaskSelector isn't a "real" Selector, it's a dummy object because we

* want to hook into the goodness of AbstractSelector. AbstractSelector uses

* some cunning private goop (sun.misc.SharedSecrets) to hook into the current

* thread object and receive notifications when the thread is interrupted.

* Since that's what we're after, we implement AbstractSelector simply to

* receive that notification.

*/

class NativeTaskSelector extends AbstractSelector {

protected NativeTaskSelector(NativeTask task_) {

super(null);

task = task_;

}

public void registerStart() { begin(); }

public void registerEnd() { end(); }

final private NativeTask task;

@Override

protected void implCloseSelector() throws IOException {

}

@Override

protected SelectionKey register(AbstractSelectableChannel arg0, int arg1,

Object arg2) {

throw new UnsupportedOperationException();

}

@Override

public Set<SelectionKey> keys() {

throw new UnsupportedOperationException();

}

@Override

public int select() throws IOException {

throw new UnsupportedOperationException();

}

@Override

public int select(long arg0) throws IOException {

throw new UnsupportedOperationException();

}

@Override

public int selectNow() throws IOException {

throw new UnsupportedOperationException();

}

@Override

public Set<SelectionKey> selectedKeys() {

throw new UnsupportedOperationException();

}

@Override

public Selector wakeup() {

System.out.println("Received notification of Thread interrupt");

task.wakeupTask();

return this;

}

}