You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jv...@apache.org on 2008/11/06 19:04:03 UTC
svn commit: r711930 -
/mina/sandbox/jvermillard/mina-cleaning/core/src/main/java/org/apache/mina/core/session/IdleStatusChecker.java
Author: jvermillard
Date: Thu Nov 6 10:04:01 2008
New Revision: 711930
URL: http://svn.apache.org/viewvc?rev=711930&view=rev
Log:
comments on IdleStatusChecker
Modified:
mina/sandbox/jvermillard/mina-cleaning/core/src/main/java/org/apache/mina/core/session/IdleStatusChecker.java
Modified: mina/sandbox/jvermillard/mina-cleaning/core/src/main/java/org/apache/mina/core/session/IdleStatusChecker.java
URL: http://svn.apache.org/viewvc/mina/sandbox/jvermillard/mina-cleaning/core/src/main/java/org/apache/mina/core/session/IdleStatusChecker.java?rev=711930&r1=711929&r2=711930&view=diff
==============================================================================
--- mina/sandbox/jvermillard/mina-cleaning/core/src/main/java/org/apache/mina/core/session/IdleStatusChecker.java (original)
+++ mina/sandbox/jvermillard/mina-cleaning/core/src/main/java/org/apache/mina/core/session/IdleStatusChecker.java Thu Nov 6 10:04:01 2008
@@ -25,6 +25,7 @@
import org.apache.mina.core.future.CloseFuture;
import org.apache.mina.core.future.IoFuture;
import org.apache.mina.core.future.IoFutureListener;
+import org.apache.mina.core.service.IoService;
import org.apache.mina.util.ConcurrentHashSet;
/**
@@ -74,6 +75,10 @@
sessions.remove(session);
}
+ /**
+ * get a runnable task able to be scheduled in the {@link IoService} executor.
+ * @return
+ */
public NotifyingTask getNotifyingTask() {
return notifyingTask;
}
@@ -84,6 +89,11 @@
public class NotifyingTask implements Runnable {
private volatile boolean cancelled;
private volatile Thread thread;
+
+ // we forbid instantiation of this class outside
+ private NotifyingTask() {
+
+ }
public void run() {
thread = Thread.currentThread();
@@ -105,6 +115,9 @@
}
}
+ /**
+ * stop execution of the task
+ */
public void cancel() {
cancelled = true;
Thread thread = this.thread;