simpletaskobserver.java

基于图形化的多线程下载器

import java.net.*;
import java.util.*;
import java.io.*;

public class SimpleTaskObserver extends Thread {

	public TaskInfo taskInfo = null;
	public long lastAcquiredSize = 0;
	public boolean run = true;
	public long startTime = 0;
	public long duringTime = 0;
	public long speed = 0;

	public SimpleTaskObserver(TaskInfo taskInfo) {
		this.taskInfo = taskInfo;
		lastAcquiredSize = taskInfo.getAcquiredSize();
		startTime = System.currentTimeMillis();
	}

	public void setRun(boolean run) {
		this.run = run;
	}

	@Override
	public void run() {
		while (run) {
			MyUtil.sleepNow(1000);
			duringTime = (System.currentTimeMillis() - startTime) / 1000;
			speed = (taskInfo.getAcquiredSize() - lastAcquiredSize) / 1000 /duringTime;
			System.out.println("mainTaskThread speed: " + speed + " kb/s");

		}
	}

}