Muy buena indicacion. TE puedo confirmar que:
- la variable $flatValidLines es incrementada por los 4 procesos con la funcion printFlatDecodedLine
- la funcion que sirve para imprimir dicha variable (printFlatReport)
Sigo investigando...
-
- Publicidad
Problema con multihilo
29 mensajes
• Página 3 de 3 • 1, 2, 3
Publicidad
por fgalves » 2006-10-16 04:45 @239
Aqui os enseño la función a la que se llama para imprimir todos los reports.
Es decir, desde esta función, se llama a la función printFlatReport, ya que Outbrs.pm es una instancia de flatProjection (un report concreto):
Es decir, desde esta función, se llama a la función printFlatReport, ya que Outbrs.pm es una instancia de flatProjection (un report concreto):
Using perl Syntax Highlighting
sub printReports {
my $globalParams = $_[0];
my $reportHeader = $_[1];
my $status = 0;
if (defined $xmlProjections[0]) {
foreach my $xmlProjection (@xmlProjections) {
$status = $xmlProjection->printXMLReport($globalParams, $reportHeader);
if ($status != 0) {
&Logger::logError("$xmlProjection XML report was not properly created.\n");
}
}
}
if (defined $flatProjections[0]) {
foreach my $flatProjection (@flatProjections) {
$status = $flatProjection->printFlatReport($globalParams, $reportHeader);
if ($status != 0) {
&Logger::logError("$flatProjection Flat report was not properly created.\n");
}
}
}
return $status;
}
my $globalParams = $_[0];
my $reportHeader = $_[1];
my $status = 0;
if (defined $xmlProjections[0]) {
foreach my $xmlProjection (@xmlProjections) {
$status = $xmlProjection->printXMLReport($globalParams, $reportHeader);
if ($status != 0) {
&Logger::logError("$xmlProjection XML report was not properly created.\n");
}
}
}
if (defined $flatProjections[0]) {
foreach my $flatProjection (@flatProjections) {
$status = $flatProjection->printFlatReport($globalParams, $reportHeader);
if ($status != 0) {
&Logger::logError("$flatProjection Flat report was not properly created.\n");
}
}
}
return $status;
}
Coloreado en 0.005 segundos, usando GeSHi 1.0.8.4
- fgalves
- Perlero nuevo
- Mensajes: 210
- Registrado: 2006-09-25 13:54 @621
por fgalves » 2006-10-16 06:54 @329
El meollo de la cuestión está en cómo conservar el valor de $flatValidLines.
Dicha variable es incrementada en paralelo por muchos procesos (forks), pero cada uno de forma independiente.
Lo que no puedo hacer es bloquearla con un semáforo, porque retardaría enormemente el tiempo de ejecución.
He probado de declarar otra variable global y ir incrementando con el valor de $flatValidLines, pero dicha variable también vale 0 al final.
¡¡¡Que rollo de problema!!!!
Dicha variable es incrementada en paralelo por muchos procesos (forks), pero cada uno de forma independiente.
Lo que no puedo hacer es bloquearla con un semáforo, porque retardaría enormemente el tiempo de ejecución.
He probado de declarar otra variable global y ir incrementando con el valor de $flatValidLines, pero dicha variable también vale 0 al final.
¡¡¡Que rollo de problema!!!!
- fgalves
- Perlero nuevo
- Mensajes: 210
- Registrado: 2006-09-25 13:54 @621
por explorer » 2006-10-16 07:15 @344
Es que es natural que al ser foks, los procesos incrementen la variable de forma independiente.
Cuando dices final, ¿a qué te refieres? ¿a la ejecución de todos los procesos o de sólo el padre? Si el padre no participa en el proceso general, es normal que sus variables siempre sean 0.
Cuando dices final, ¿a qué te refieres? ¿a la ejecución de todos los procesos o de sólo el padre? Si el padre no participa en el proceso general, es normal que sus variables siempre sean 0.
JF^D Perl programming & Raku programming. Grupo en Telegram: https://t.me/Perl_ES
-
explorer - Administrador
- Mensajes: 14486
- Registrado: 2005-07-24 18:12 @800
- Ubicación: Valladolid, España
por Perl user » 2006-10-16 12:29 @562
Que tal,
Revisando un poco tu código ( que aun no logro comprender tanto ), veo que muy buena parte de tu problemita es cuestión de diseño...
Te explico:
- Tal parece que todas las funciones que usas no son exportadas a tu espacio de nombres actual, todo lo haces accediendo indirectamente a la función por medio del paquete ( eso podría provocarte algunos fallos de seguridad ).
La recomendación es que verifiques como crear módulos y como exportar los símbolos que nada mas requieras.
- veo por allí que mandas un contador a una funcion que ( creo... ) genera una lista de lo que tienes que esperar? no lo sé, se me hace innecesario...
Para esperar por tus procesos hijos ( sin importar cual ) basta con utilizar waitpid( -1, WNOHANG ) como te lo indiqué en un post anterior, de esa manera no te tienes que preocupar por los pids del todo, deja que el sistema lo haga.
- De la misma manera, en un comentario que hice hace días te comentaba sobre sincronización de información, algo que estás ignorando en el código que me muestras... No tienes nada de sincronización para acceder al contador que tienes, no le hagas tanta confianza al scheduler del sistema, es dificil de entender en cuanto a su funcionamiento. Utiliza algo como shared memory o semaforos para sincronizar eso.
Y bueno, no he visto la mayor parte del código, pero eso es principalmente lo que noto de fallo, y en conclusión se resume a un mal diseño para algo multiprocesos (ojo, no multithread).
Saludos,
Revisando un poco tu código ( que aun no logro comprender tanto ), veo que muy buena parte de tu problemita es cuestión de diseño...
Te explico:
- Tal parece que todas las funciones que usas no son exportadas a tu espacio de nombres actual, todo lo haces accediendo indirectamente a la función por medio del paquete ( eso podría provocarte algunos fallos de seguridad ).
La recomendación es que verifiques como crear módulos y como exportar los símbolos que nada mas requieras.
- veo por allí que mandas un contador a una funcion que ( creo... ) genera una lista de lo que tienes que esperar? no lo sé, se me hace innecesario...
Para esperar por tus procesos hijos ( sin importar cual ) basta con utilizar waitpid( -1, WNOHANG ) como te lo indiqué en un post anterior, de esa manera no te tienes que preocupar por los pids del todo, deja que el sistema lo haga.
- De la misma manera, en un comentario que hice hace días te comentaba sobre sincronización de información, algo que estás ignorando en el código que me muestras... No tienes nada de sincronización para acceder al contador que tienes, no le hagas tanta confianza al scheduler del sistema, es dificil de entender en cuanto a su funcionamiento. Utiliza algo como shared memory o semaforos para sincronizar eso.
Y bueno, no he visto la mayor parte del código, pero eso es principalmente lo que noto de fallo, y en conclusión se resume a un mal diseño para algo multiprocesos (ojo, no multithread).
Saludos,
- Perl user
- Maestro honorario
- Mensajes: 271
- Registrado: 2004-11-03 21:11 @924
por fgalves » 2006-10-17 03:25 @184
¡¡¡Hola a todos!!!
Siento no haber podido explicar antes el origen del problema pues ayer tenía mucha prisa y no resolví el problema hasta las 7 de la tarde, justo antes de largarme a casa. Esa es la función del foro, que sirva de ejemplo para la demás gente como yo, así que aquí estoy para explicaros brevemente lo que pasaba.
De hecho, tal y como dice nuestro amigo "Perl User", se trataba de un problema de diseño. La variable $flatValidLines era incrementada correctamente por cada proceso hijo, y en el propio Perl module donde dicha variable estaba declarada, existía una función que se encargaba de incrementar dicha variable tomando en cuenta el resultado obtenido por los demás procesos hijos.
El problema: dicha función nunca era llamada a nivel superior, es decir, simplemente no era usada.
De hecho, no he sido yo el que ha diseñado dicha aplicación; yo soy nuevo en la empresa, acabo de llegar hace un mes y me encuentro con toda esa maraña de funciones y expresiones raras en un lenguaje que yo jamás había utilizado.
Pero bueno, por fin está arreglado y ahora toca continuar y seguir arreglando otros problemas que vendrán.
Un saludo y gracias a todos por la ayuda e interés.
Felipe
Siento no haber podido explicar antes el origen del problema pues ayer tenía mucha prisa y no resolví el problema hasta las 7 de la tarde, justo antes de largarme a casa. Esa es la función del foro, que sirva de ejemplo para la demás gente como yo, así que aquí estoy para explicaros brevemente lo que pasaba.
De hecho, tal y como dice nuestro amigo "Perl User", se trataba de un problema de diseño. La variable $flatValidLines era incrementada correctamente por cada proceso hijo, y en el propio Perl module donde dicha variable estaba declarada, existía una función que se encargaba de incrementar dicha variable tomando en cuenta el resultado obtenido por los demás procesos hijos.
El problema: dicha función nunca era llamada a nivel superior, es decir, simplemente no era usada.
De hecho, no he sido yo el que ha diseñado dicha aplicación; yo soy nuevo en la empresa, acabo de llegar hace un mes y me encuentro con toda esa maraña de funciones y expresiones raras en un lenguaje que yo jamás había utilizado.
Pero bueno, por fin está arreglado y ahora toca continuar y seguir arreglando otros problemas que vendrán.
Un saludo y gracias a todos por la ayuda e interés.
Felipe
- fgalves
- Perlero nuevo
- Mensajes: 210
- Registrado: 2006-09-25 13:54 @621
29 mensajes
• Página 3 de 3 • 1, 2, 3
¿Quién está conectado?
Usuarios navegando por este Foro: No hay usuarios registrados visitando el Foro y 0 invitados