Dada una matriz de números enteros rectangular, calcular de forma paralela dos listas: una con los valores positivos y otra con los valores negativos. Lo que llevo hasta ahora es lo siguiente:
class Worker
{
private int[,] A;
private int índiceDesde, índiceHasta;
private List<int> listaN, listaP;
/// <summary>
/// Trabajor encargado de sacar las listas Positivas y Negativas de la matriz A dejándolas sobre la listaP y la listaN
/// </summary>
/// <param name="índiceDesde"></param>
/// <param name="índiceHasta"></param>
/// <param name="A">Matriz a valorar</param>
/// <param name="listaP">Lista de numeros Positivos</param>
/// <param name="listaN">Lista de numeros Negativos</param>
internal Worker(int índiceDesde, int índiceHasta, int[,] A, ref List<int> listaP, ref List<int> listaN)
{
this.A = A;
this.índiceDesde = índiceDesde;
this.índiceHasta = índiceHasta;
this.listaP = listaP;
this.listaN = listaN;
}
/// <summary>
/// Metodo que calcula Las listas positivas y negativas de la matiz A
/// </summary>
internal void Calcular()
{
int contador = 0;
for (int k = this.índiceDesde; k < this.índiceHasta; k++)
{
for (int i = 0; i < A.Length; i++)
{
for (int j = 0; j < A.Length; j++)
{
if (A[i, j] < 0)
{
listaN.Add(A[i, j]);
}
else
{
listaP.Add(A[i, j]);
}
}
}
}
}
}
Clase Master:
class Master
{
private int[,] matrizA;
private int numeroHilos;
private List<int> listaN, listaP;
public Master(int[,] matrizA, ref List<int> listaP, ref List<int> listaN, int posPorHilos)
{
this.matrizA = matrizA;
this.numeroHilos = numHilos(matrizA, posPorHilos);
this.listaN = listaN;
this.listaP = listaP;
}
/// <summary>
/// Método Auxiliar (opcional)
/// </summary>
/// <param name="matrizA"></param>
/// <param name="posPorHilos"></param>
/// <returns></returns>
private int numHilos(int[,] matrizA, int posPorHilos)
{
return (matrizA.Length / posPorHilos) / 2;
}
public void Calcular()
{
//REservamos espacio para el array de trabajadores
Worker[] workers = new Worker[numeroHilos];
int elementosPorHilo = this.matrizA.Length / numeroHilos;
for (short i = 0; i < numeroHilos; i++)
workers[i] = new Worker(i * elementosPorHilo,
(i < this.numeroHilos - 1) ? (i + 1) * elementosPorHilo - 1 : this.matrizA.Length - 1,
matrizA,ref listaP,ref listaN);
//Creamos y lanzamos los hilos trabajadores
Thread[] hilos = new Thread[workers.Length];
for (short i = 0; i < hilos.GetLength(0); i++)
{
hilos[i] = new Thread(workers[i].Calcular);
hilos[i].Name = "Worker Matriz ListaPositivos y Lista Negativos " + (i);
hilos[i].Priority = ThreadPriority.BelowNormal;
hilos[i].Start();
}
//Esperamos por la finalización de los hilos trabajadores.
foreach (Thread hilo in hilos)
hilo.Join();
}
}
Clase Program:
public class Program
{
static void Main(string[] args)
{
int[,] A = CrearMatrizAleatoria(4, 5, -10, 10);
List<int> lista1, lista2;
int numeroHilos = 5;
System.Console.WriteLine("Matriz A");
mostrarMatriz(A);
// Ejercicio 1.
ejercicio1(A, out lista1, out lista2, 4); //Modificar la signatura del método ejercicio1 para que reciba como parámetro las partes en que se dividirá A
System.Console.WriteLine("Ejercicio1. Calcula Listas sin TPL y con nPartes hilos");
mostrar(lista1); mostrar(lista2);
}
//
// Ejercicio1
// Versión paralela sin TPL y numeroHilos = nPartes
//
public static void ejercicio1(int[,] A, out List<int> lista1, out List<int> lista2, int numeroHilos)
{
lista1 = null; lista2 = null;
//List<int> listaN = null;
//List<int> listaP = null;
//int numeroHilos = 0;
//mostrarMatriz(A);
///CODIGO
List<int> listaN = null;
List<int> listaP = null;
System.Console.WriteLine("\tMatriz Original\n");
mostrarMatriz(A);
Master master = new Master(A, ref lista1, ref lista2, numeroHilos);
master.Calcular();
}
public static int[,] CrearMatrizAleatoria(int filas, int columnas, int menor, int mayor) {
int[,] vector = new int[filas, columnas];
Random random = new Random(1);
for (int i = 0; i < filas; i++)
for (int j = 0; j < columnas; j++)
vector[i,j] = (int)random.Next(menor, mayor + 1);
return vector;
}
public static void mostrarMatriz(int [,] matriz)
{
for (int i = 0; i < matriz.GetLength(0); i++)
{
for (int j = 0; j < matriz.GetLength(1); j++)
System.Console.Write(matriz[i,j]+" ");
System.Console.WriteLine();
}
}
public static void mostrar<T>(IEnumerable<T> lista)
{
foreach (T x in lista) {
Console.Write(x + " ");
}
Console.WriteLine();
}
}
}
El programa al ejecutarlo "casca", me da error en la clase Worker a la altura de:
listaN.Add(A[i, j]);
Aunque creo que no debe ser lo único que tengo mal, necesitaría algo de ayuda y orientación, gracias.
Me aparece el siguiente error al compilar:
Excepción no controlada: Excepción no controlada: System.NullReferenceExcepti stablecida como instancia de un objeto. en Matriz.Worker.Calcular() en C:\Users\powerserv CURSO\Segundo Semestre\TPP\Exe en System.Threading.ThreadHelper.ThreadStart_Cont en System.Threading.ExecutionContext.RunInternal( ntext, ContextCallback callback, Object state, Boole en System.Threading.ExecutionContext.Run(Executio ontextCallback callback, Object state, Boolean prese en System.Threading.ExecutionContext.Run(Executio ontextCallback callback, Object state) en System.Threading.ThreadHelper.ThreadStart() System.NullReferenceException: Referencia a objeto n de un objeto. en Matriz.Worker.Calcular() en C:\Users\powerserv CURSO\Segundo Semestre\TPP\Exe en System.Threading.ThreadHelper.ThreadStart_Cont en System.Threading.ExecutionContext.RunInternal( ntext, ContextCallback callback, Object state, Boole en System.Threading.ExecutionContext.Run(Executio ontextCallback callback, Object state, Boolean prese en System.Threading.ExecutionContext.Run(Executio ontextCallback callback, Object state) en System.Threading.ThreadHelper.ThreadStart()