Esta sección te permite ver todos los mensajes escritos por este usuario. Ten en cuenta que sólo puedes ver los mensajes escritos en zonas a las que tienes acceso en este momento.
Cita de: xoker en 26 Enero 2014, 19:29 PM
Desde el inicio el codigo que tengo en mi PC funciona perfectamente (al copiarlo me puse una llave de mas, error mio que ni siquiera sabia que habia puesto y que imagino que nadie se dio cuenta al principio hasta que lo mencionaste mas tarde)
Cita de: xoker en 26 Enero 2014, 19:29 PM
Esto se estudia al comienzo en la universidad, lo se porque en segundo de carrera estoy cursando una asignatura sobre paralelismo y todos lo hacemos al principio... y con el tiempo, ves la burrada que significa.
Cita de: xoker en 24 Enero 2014, 21:22 PM
//Supongamos que antes se ha declarado esto:
//Object cerrojo = new Object();Código [Seleccionar]switch(tipoHilo){
case 0:
for(int i=0; i<nVueltas; i++)
synchronized(cerrojo){ n=n+1;}; // <--- Cambio de cerrojo
break;
case 1:
for(int i=0; i<nVueltas; i++){
synchronized(cerrojo){n=n-1;}; // <--- Cambio de cerrojo
break;
}
Citarswitch(tipoHilo){
case 0:
for(int i=0; i<nVueltas; i++)
synchronized(cerrojo){ n=n+1;}; // <--- Cambio de cerrojo
break;
case 1:
for(int i=0; i<nVueltas; i++){
synchronized(cerrojo){n=n-1;}; // <--- Cambio de cerrojo
break;
}
package main;
public class Hilo extends Thread {
private int tipoHilo;
private static Integer n = new Integer(0);
private int nVueltas;
public Hilo(int nVueltas, int tipoHilo)
{this.nVueltas=nVueltas; this.tipoHilo=tipoHilo;}
public void run()
{
Object cerrojo = new Object();
switch(tipoHilo){
case 0:
for(int i=0; i<nVueltas; i++)
synchronized(cerrojo){ n=n+1;};
break;
case 1:
for(int i=0; i<nVueltas; i++)
synchronized(cerrojo){n=n-1;};
break;
}
}
public static void main(String[] args)
throws Exception
{
Hilo p = new Hilo(10000, 0);
Hilo q = new Hilo(10000, 1);
p.start();
q.start();
p.join();
q.join();
System.out.println(n);
}
}
Cita de: ~ Yoya ~ en 19 Enero 2014, 22:53 PM
La razón porque al principio no funcionaba es porque habías puesto el keyword synchronized dentro del un loop. Cuando se iniciaba un ciclo en el loop, uno de los 2 thread tomaba el lock y el otro esperaba a que liberen el lock.
El problema esta en que el lock se libera cuando termina cada ciclo (son 10,000 ciclos como haz indicado), y puede pasar 2 cosas:
- El thread que habia tomado el lock toma el lock de nuevo
- El thread que estaba esperando que liberen el lock toma el lock.
Por lo tanto, en un momento la variable se puede incrementar y en el siguiente puede que disminuya, y en el siguiente puede incrementarse o disminuirse, y asi.
CitarA read / write lock is more sophisticated lock than the Lock implementations shown in the text Locks in Java. Imagine you have an application that reads and writes some resource, but writing it is not done as much as reading it is. Two threads reading the same resource does not cause problems for each other, so multiple threads that want to read the resource are granted access at the same time, overlapping. But, if a single thread wants to write to the resource, no other reads nor writes must be in progress at the same time
Cita de: wikipediaIn computer science, the first and second readers-writers problems are examples of a common computing problem in concurrency. The two problems deal with situations in which many threads must access the same shared memory at one time, some reading and some writing, with the natural constraint that no process may access the share for reading or writing while another process is in the act of writing to it. (In particular, it is allowed for two or more readers to access the share at the same time.)
Cita de: wikipediaLa seguridad en hilos es un concepto de programación aplicable en el contexto de los programas multihilos. Una pieza de código es segura en cuanto a los hilos si funciona correctamente durante la ejecución simultánea de múltiples hilos. En particular, debe satisfacer la necesidad de que múltiples hilos accedan a los mismos datos compartidos, y la necesidad de que una pieza compartida de datos sea accedida por solo un hilo en un momento dado.
public class Hilo extends Thread {
private int tipoHilo;
private static Integer n = new Integer(0);
private int nVueltas;
public Hilo(int nVueltas, int tipoHilo) {
this.nVueltas = nVueltas;
this.tipoHilo = tipoHilo;
}
public void run() {
synchronized (n) {
switch (tipoHilo) {
case 0:
for (int i = 0; i < nVueltas; i++)
n = n + 1;
;
break;
case 1:
for (int i = 0; i < nVueltas; i++)
n = n - 1;
;
break;
}
}
}
public static void main(String[] args) throws Exception {
Hilo p = new Hilo(10000, 0);
Hilo q = new Hilo(10000, 1);
p.start();
q.start();
p.join();
q.join();
System.out.println(n);
}
}