package project;

import java.util.Vector;

public class ThreadedMatrix implements Runnable {
    //que of matrices that need to be calculated
    public Vector<Matrix> que = new Vector<Matrix>();
    //total result of all the threads
    public static double result;
    //do we want to know when each thread starts and stops
    public boolean quiet;
    //which thread this is // an index
    public int ThreadNumber;
    //when this thread started and how long it took to finish
    long starttime, calcTime;
    //reference to the actual thread, necessary for joining/waiting
    public Thread thisThread;
    //constructor
    public ThreadedMatrix(boolean _q, int _tn) {
        quiet = _q;
        ThreadNumber = _tn;
    }
    //push a matrix into the que and tell it that it's being calculated by this thread
    public void Push(Matrix m) {
        que.add(m);
        m.thread = this;
    }
    //remove a matrix
    public void Pop(Matrix m) {
        que.remove(m);
    }
    //remove the top matrix. never actually used but added for the heck of it
    public void Pop() {
        que.remove(que.size() - 1);
    }
    //top matrix in the que
    public Matrix Top() {
        return que.get(que.size() - 1);
    }
    //called when the thread starts
    @Override
    public void run() {
        //report when the thread started
        if (!quiet) {
            starttime = System.nanoTime();
            System.out.println("Thread " + ThreadNumber + " started");
        }
        //every thread is running until every single thread has no more matrices in their ques
        while (true) {
            if (que.size() > 0) {
                Matrix _t = Top();
                result += _t.Determinant(quiet) * _t.valueInParent;
            }
            //check if every thread has no more matrices in it's que
            boolean finished = true;
            for (ThreadedMatrix thread : Matrix.threadedMatrices) {
                if (thread.que.size() > 0) {
                    finished = false;
                }
            }
            //stop the threads
            if (finished) {
                break;
            }
        }
        //report when the thread finished
        if (!quiet) {
            calcTime = System.nanoTime() - starttime;
            System.out.println("Thread " + ThreadNumber + " stopped\nExecution time was " + calcTime);
        }
    }

}