--- a/src/org/eclipse/jetty/io/nio/SelectorManager.java	Wed Oct 12 22:16:36 2016 -0600
+++ b/src/org/eclipse/jetty/io/nio/SelectorManager.java	Thu Oct 13 00:54:10 2016 -0600
@@ -60,9 +60,7 @@
 
 	private int _maxIdleTime;
 	private long _lowResourcesConnections;
-	private SelectSet[] _selectSet;
-	private int _selectSets = 1;
-	private volatile int _set=0;
+	private SelectSet _selectSet;
 
 	/* ------------------------------------------------------------ */
 	/**
@@ -75,34 +73,14 @@
 	}
 
 	/* ------------------------------------------------------------ */
-	/**
-	 * @param selectSets number of select sets to create
-	 */
-	public void setSelectSets(int selectSets)
-	{
-		long lrc = _lowResourcesConnections * _selectSets;
-		_selectSets=selectSets;
-		_lowResourcesConnections=lrc/_selectSets;
-	}
-
-	/* ------------------------------------------------------------ */
 	/** Register a channel
 	 * @param channel
 	 */
 	public void register(SocketChannel channel)
 	{
-		// The ++ increment here is not atomic, but it does not matter.
-		// so long as the value changes sometimes, then connections will
-		// be distributed over the available sets.
-
-		int s = _set++;
-		if (s<0)
-			s=-s;
-		s=s%_selectSets;
-		SelectSet[] sets = _selectSet;
-		if (sets!=null)
+		SelectSet set = _selectSet;
+		if (set!=null)
 		{
-			SelectSet set=sets[s];
 			set.addChange(channel);
 		}
 	}
@@ -113,7 +91,7 @@
 	 */
 	public long getLowResourcesConnections()
 	{
-		return _lowResourcesConnections*_selectSets;
+		return _lowResourcesConnections;
 	}
 
 	/* ------------------------------------------------------------ */
@@ -125,7 +103,7 @@
 	 */
 	public void setLowResourcesConnections(long lowResourcesConnections)
 	{
-		_lowResourcesConnections=(lowResourcesConnections+_selectSets-1)/_selectSets;
+		_lowResourcesConnections = lowResourcesConnections;
 	}
 
 
@@ -138,55 +116,48 @@
 	@Override
 	protected void doStart() throws Exception
 	{
-		_selectSet = new SelectSet[_selectSets];
-		for (int i=0;i<_selectSet.length;i++)
-			_selectSet[i]= new SelectSet(i);
+		_selectSet = new SelectSet();
 
 		super.doStart();
 
 		// start a thread to Select
-		for (int i=0;i<_selectSets;i++)
+		execute(new Runnable()
 		{
-			final int id=i;
-			execute(new Runnable()
+			public void run()
 			{
-				public void run()
+				String name=Thread.currentThread().getName();
+				try
 				{
-					String name=Thread.currentThread().getName();
-					try
-					{
-						SelectSet[] sets=_selectSet;
-						if (sets==null)
-							return;
-						SelectSet set=sets[id];
+					SelectSet set = _selectSet;
+					if (set==null)
+						return;
 
-						Thread.currentThread().setName(name+" Selector"+id);
-						LOG.debug("Starting {} on {}",Thread.currentThread(),this);
-						while (isRunning())
+					Thread.currentThread().setName(name+" Selector");
+					LOG.debug("Starting {} on {}",Thread.currentThread(),this);
+					while (isRunning())
+					{
+						try
 						{
-							try
-							{
-								set.doSelect();
-							}
-							catch(IOException e)
-							{
-								LOG.trace("",e);
-							}
-							catch(Exception e)
-							{
-								LOG.warn("",e);
-							}
+							set.doSelect();
+						}
+						catch(IOException e)
+						{
+							LOG.trace("",e);
+						}
+						catch(Exception e)
+						{
+							LOG.warn("",e);
 						}
 					}
-					finally
-					{
-						LOG.debug("Stopped {} on {}",Thread.currentThread(),this);
-						Thread.currentThread().setName(name);
-					}
 				}
+				finally
+				{
+					LOG.debug("Stopped {} on {}",Thread.currentThread(),this);
+					Thread.currentThread().setName(name);
+				}
+			}
 
-			});
-		}
+		});
 	}
 
 
@@ -194,15 +165,11 @@
 	@Override
 	protected void doStop() throws Exception
 	{
-		SelectSet[] sets= _selectSet;
-		_selectSet=null;
-		if (sets!=null)
+		SelectSet set = _selectSet;
+		_selectSet = null;
+		if (set!=null)
 		{
-			for (SelectSet set : sets)
-			{
-				if (set!=null)
-					set.stop();
-			}
+			set.stop();
 		}
 		super.doStop();
 	}
@@ -217,25 +184,20 @@
 	public void dump(Appendable out, String indent) throws IOException
 	{
 		AggregateLifeCycle.dumpObject(out,this);
-		AggregateLifeCycle.dump(out,indent,TypeUtil.asList(_selectSet));
+		AggregateLifeCycle.dump(out,indent,Collections.singletonList(_selectSet));
 	}
 
 
-	public class SelectSet implements Dumpable
+	public final class SelectSet implements Dumpable
 	{
-		private final int _setID;
 		private volatile long _now = System.currentTimeMillis();
 
-		private volatile SaneSelector _selector;
+		private final SaneSelector _selector;
 
-		private volatile Thread _selecting;
 		private ConcurrentMap<SelectChannelEndPoint,Object> _endPoints = new ConcurrentHashMap<SelectChannelEndPoint, Object>();
 
-		SelectSet(int acceptorID) throws Exception
+		SelectSet() throws IOException
 		{
-			_setID=acceptorID;
-
-			// create a selector;
 			_selector = new SaneSelector();
 		}
 
@@ -260,26 +222,15 @@
 				}
 			}
 		}
-		/* ------------------------------------------------------------ */
-		/**
-		 * Select and dispatch tasks found from changes and the selector.
-		 *
-		 * @throws IOException
-		 */
+
 		private void doSelect() throws IOException
 		{
 			try
 			{
-				_selecting=Thread.currentThread();
-				final SaneSelector selector = _selector;
-				// Stopped concurrently ?
-				if (selector == null)
-					return;
-
-				selector.select();
+				_selector.select();
 
 				// Look for things to do
-				for (SelectionKey key: selector.selectedKeys())
+				for (SelectionKey key: _selector.selectedKeys())
 				{
 					try
 					{
@@ -296,7 +247,6 @@
 							SelectChannelEndPoint endpoint = (SelectChannelEndPoint)key.attachment();
 							endpoint.schedule();
 						}
-						key = null;
 					}
 					catch (CancelledKeyException e)
 					{
@@ -312,7 +262,7 @@
 				}
 
 				// Everything always handled
-				selector.selectedKeys().clear();
+				_selector.selectedKeys().clear();
 
 				_now = System.currentTimeMillis();
 			}
@@ -327,10 +277,6 @@
 			{
 				LOG.trace("",e);
 			}
-			finally
-			{
-				_selecting=null;
-			}
 		}
 
 		public SelectorManager getManager()
@@ -369,18 +315,14 @@
 			// close endpoints and selector
 			for (SelectionKey key : _selector.keys())
 			{
-				Object att=key.attachment();
-				if (att instanceof EndPoint)
+				EndPoint endpoint = (EndPoint)key.attachment();
+				try
 				{
-					EndPoint endpoint = (EndPoint)att;
-					try
-					{
-						endpoint.close();
-					}
-					catch(IOException e)
-					{
-						LOG.trace("",e);
-					}
+					endpoint.close();
+				}
+				catch(IOException e)
+				{
+					LOG.trace("",e);
 				}
 			}
 
@@ -392,7 +334,6 @@
 			{
 				LOG.trace("",e);
 			}
-			_selector = null;
 		}
 
 		public String dump()
@@ -402,7 +343,7 @@
 
 		public void dump(Appendable out, String indent) throws IOException
 		{
-			out.append(String.valueOf(this)).append(" id=").append(String.valueOf(_setID)).append("\n");
+			out.append(String.valueOf(this)).append("\n");
 			AggregateLifeCycle.dump(out,indent,Collections.emptyList());
 		}