@Override
	public void run( ) {
		this.running = true;
		
		while ( this.running ) {
			if ( this.listeners.size( ) != 0 ) {
				final EventType elem = this.queue.poll( );
				
				if ( elem != null )
					for (final IListener<EventType> li : this.listeners)
						li.handle(elem);
			}
			
			try {
				Thread.sleep(5);
			} catch ( final InterruptedException e ) {
				e.printStackTrace( );
			}
		}
	}