workerthread.java

来自「通过线程控制来打印出julia集」· Java 代码 · 共 32 行

public class WorkerThread extends Thread {
	DataBuffer inputBuffer, displayBuffer;

	DataPacket p;

	JuliaCalc j;
boolean quit=false;
	WorkerThread(DataBuffer inputBuffer, DataBuffer displayBuffer,
			JuliaCalc juliaCalc) {
		this.inputBuffer = inputBuffer;
		this.displayBuffer = displayBuffer;
		j = juliaCalc;
	}

	public void run() {
		while (!quit) {
			p = inputBuffer.get();				//get inputBuffer
			displayBuffer.put(j.calculate(p));	//put the calculated DataPacket to displayBuffer
			try {
				Thread.sleep(0);				//for speed
			} catch (InterruptedException e) {
			}
		}
	}
	public void quit(){						//if quit , do nothing
		quit=true;
	}
	public void restart(){
		quit=false;
	}
}