public class WorkerThread extends Thread {
	...
	@Override
	public void run() {
		while(!stop) {
			checkNewFilesInDir();
			publishStatus();
			Thread.sleep(200);
		}
	}
}