wdscmonitorthread.java

以前做的一个j2ee的项目

package gov.gdlt.ssgly.taxcore.taxblh.wdsc.yhswdsc;

import java.util.*;

public class WDSCmonitorThread extends Thread {
    private Vector threads;
    private int count = 0;
    private Vector data = new Vector(), tempVector = null;
    private boolean bOver = true;
    public WDSCmonitorThread() {
    }

    public WDSCmonitorThread(Vector thread) {
        threads = thread;
        count = threads.size();
    }

    public static void main(String[] args) {
        WDSCmonitorThread wdscmonitorthread = new WDSCmonitorThread();
    }
    public void run() {

    }

    public Vector getVectorData() throws InterruptedException {
        WDSCyhsxxThread tempThread = null;
        while (bOver) {
            bOver = false;
            this.sleep(2);
            for (int i = 0; i < count; i++) {
                tempThread = (WDSCyhsxxThread)threads.get(i);
                if (tempThread.isIsOver()) {
                    tempVector = tempThread.getVector();
                    if (tempVector != null) {
                        int c = tempVector.size();
                        for (int j = 0; j < c; j++) {
                            data.add(tempVector.get(j));
                        }
                        tempThread.setVector(null);
                    }
                } else {
                    bOver = true;
                }
            }
        }
        return data;
    }

    public Vector getData() {
        return data;
    }

    public Vector getTempVector() {
        return tempVector;
    }

    public int getCount() {
        return count;
    }

    public Vector getThreads() {
        return threads;
    }


    public void setData(Vector data) {
        this.data = data;
    }

    public void setTempVector(Vector tempVector) {
        this.tempVector = tempVector;
    }

    public void setCount(int count) {
        this.count = count;
    }

    public void setThreads(Vector threads) {
        this.threads = threads;
    }
}