The Big Programming Thread - Page 199

public class sumaMat{
     //this method will add both matrices and return the resulting one.
    public static float[][] suma(float[][] mat1,float[][] mat2){
        if(mat1.length!=mat2.length || mat1[0].length!=mat2[0].length){
			System.out.println("Las matrices no son de la misma dimension por lo que no se pueden sumar");
			System.out.println("El objeto no se ha iniciado correctamente, vuelva a inicializarlo o el resultado no sera correcto");
                        System.exit(1);
                        return(mat1);
		}
        else{
            float[][]res=new float[mat1.length][mat1[0].length];
            for(int i=0;i<mat1.length;i++){
                for(int j=0;j<mat1[0].length;j++){
                    res[i][j]=mat1[i][j]+mat2[i][j];
                }
            }
            return(res);
        }
    }
  
   //main method that create the matrices then add them
    public static void main(String[] args){
        int filas=10000;
        int columnas=10000;
        float[][] m,n,res;
        res=new float[filas][columnas];   
        m=new float[filas][columnas];
        for(int i=0;i<filas;i++){
            for(int j=0;j<columnas;j++){
                m[i][j]=1.0f;       
            }
        }
        n=m.clone();
        m=sumaMat.suma(m, n).clone();
    }
    
}
  

   public class sumaMatConcurrente extends Thread{
	public static float[][] m;
	public static float[][] n;
	private static float[][] res;
	private static int filas;
	private static int columnas; //column
	private int fila; //row
        
        //Constructor. Copy both matrices sent in params into the static fields.
	public sumaMatConcurrente(float [][] mat1, float[][] mat2){
		if(mat1.length!=mat2.length || mat1[0].length!=mat2[0].length){
                        System.exit(1);
		}
		else{
			res=new float[mat1.length][mat1[0].length];
			m=mat1.clone();
			n=mat2.clone();
			filas=mat1.length;
			columnas=mat1[0].length;
		}
	}
       //Second Constructor. Creates new objects with the row field initiated to the value of the row the thread will work on
	private sumaMatConcurrente(int row){
		fila=row;
	}
        
      
       //actually resolves the add of said row
	public void run(){
		for(int i=0;i<columnas;i++){
			res[fila][i]=m[fila][i]+n[fila][i];
		}
	}

        //method that start the add process, creating the threads and returning the resulting matrix.
	public float[][] Suma() throws InterruptedException{
                //Array to create threads
		sumaMatConcurrente[] resultado=new sumaMatConcurrente[filas];
                
                //Initialize row value and start the threads
		for(int i=0;i<filas;i++){
			resultado[i]=new sumaMatConcurrente(i);
			resultado[i].start();
		}
                //join 
		for(int i=0;i<filas;i++){
			resultado[i].join();
		}
		return(res);
	}

}

	public class usasumaMatConcurrente{

		public static void main(String[] args) throws InterruptedException{
			int filas=10000;
			int columnas=10000;
			float [][] m=new float[filas][columnas];
			float [][] n;
			for(int i=0;i<filas;i++){
				for(int j=0;j<filas;j++){
					m[i][j]=1.0f;
				}
			}
			n=m.clone();
			sumaMatConcurrente obj=new sumaMatConcurrente(m,n);
			m=obj.Suma().clone();                      
		}
	}