Zhikai Wang Homepage

Heteroclinic.net logo

www.heteroclinic.net

	Advanced Concurrency Topic: Runtime Deadlock Detection XXI Treetorplus3 and jdfrbeta01 Prototype no.1 Just Lock and Unlock Now we realease Treetorplus3 treetorplus3.jar,treetorLicesnse.txt. We also release jdfrbeta01.jar. 'jdfr' stands for Java Dead-lock Free Runtime. The goal is to design a runtime that will handle general concurrency issues. In the future, we may extend to operating system design/implementation. Or it may not be necessarily to design or implement something new, because we have 'injection' technology. These goals are still far. By now, what are at our hands are four prototypes. So far, we are able to profile basic concurrency events. Please note these prototype will only under the very conditions we pre-set. What works is just what worked! Any above-mentioned goals are huge tasks beyond the limited ability of the author. I spent much time studying java.util.concurrent written by Prof. Doug Lea. It corrects some very critical mis-understandings of mine. Although I am able to build these prototypes using C, C++ etc, without Java, without open source, it won't be so fast. Eclipse Java IDE also provides great help speeding up the work. 'jdfr' is open source. The jar comes with the source code inside. The first prototype is 'Just Lock and Unlock'. How to: java -cp treetorplus3.jar;jdfrbeta01.jar javax.util.concurrent.profilable.test.Test20121201_II .\ You will get the images at the folder specified. You can also try to modify this file. /* * jdfr: Java Dead-lock Free Runtime (the goal of this project) * * Author Zhikai Wang/www.heteroclinic.net * * Please keep this header. * * 2012 * / package javax.util.concurrent.profilable.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import javax.util.concurrent.profilable.LockerRoom; import javax.util.concurrent.profilable.ProfilableRunnable; import javax.util.concurrent.profilable.locks.ProfilableReentrantLock; import javax.util.concurrent.profilable.messenger.FunctorType; import javax.util.concurrent.profilable.messenger.GraphMessenger; import net.heteroclinic.graph.Bag; import net.heteroclinic.graph.ForestMinistry; class Testrun_II extends ProfilableRunnable{ public Testrun_II(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[0].lock(); LockerRoom.samplelocks[1].lock(); LockerRoom.samplelocks[2].lock(); try { TimeUnit.MILLISECONDS.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } // catch (InterruptedException e) { // // TODO Auto-generated catch block // e.printStackTrace(); // } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[1].unlock(); LockerRoom.samplelocks[2].unlock(); } } } public class Test20121201_II { // public static ProfilableReentrantLock [] locks = // new ProfilableReentrantLock [10]; // static { // for (int i = 0; i<locks.length; i++) { // locks[i] = new ProfilableReentrantLock(); // } // } /* * @param args * @throws InterruptedException / public static void main(String[] args) throws InterruptedException { Bag.tierdistance = 10.0d; Bag.nodesize = 2.5d; Bag.nodespace = 1.3d Bag.nodesize; Bag.familydistance = 2.0d * Bag.nodespace; Bag.boderspace = 3.0d * Bag.nodespace; Bag.OneDoubleequalpixels = 15; Bag.fontsize = 14; Bag.fontwidth = 8; // not accurate. Bag.edgetrim = 1.5d; // ratio if (args.length >= 1 ) { Bag.testresultfilepath = args[0]; } else { Bag.testresultfilepath = "C:\\Users\\Graphics\\Desktop\\treetortest\\"; } Bag.testunitname = "PFLB_JUST_LOCK_UNLOCK"; Bag.testresultfiletype = ".png"; Bag.treeinteveralinforest = 1.0d * Bag.nodespace; // first pass set Bag.forestministryusepresetgraphborder false // second pass set true, change the values with ForestMinistry.initGraphBorder Bag.forestministryusepresetgraphborder =true; if ( Bag.forestministryusepresetgraphborder ) { Bag.forestministryupdategraphborder = false; ForestMinistry.initGraphBorder(-1,0.0,0.0,0.0,0.0,0.0,0.0,31.375,26.0); } else { Bag.forestministryupdategraphborder = true; } CountDownLatch startSignal = new CountDownLatch(1); List<Future<?>> fl = new ArrayList<Future<?>>(); ExecutorService exec = Executors.newCachedThreadPool(); fl.add(exec.submit(new GraphMessenger(startSignal))); fl.add(exec.submit(new Testrun_II( startSignal))); TimeUnit.MILLISECONDS.sleep(2000); exec.shutdown(); for (Future<?> f : fl) f.cancel(true); ForestMinistry.printStaticGraphBorder(); } }
	Advanced Concurrency Topic: Runtime Deadlock Detection XXII Treetorplus3 and jdfrbeta01 Prototype no.2 Simple Blocker and Blockee How to: java -cp treetorplus3.jar;jdfrbeta01.jar javax.util.concurrent.profilable.test.Test20121204_I .\ You will get the images at the folder specified. You can also try to modify this file. /* * jdfr: Java Dead-lock Free Runtime (the goal of this project) * * Author Zhikai Wang/www.heteroclinic.net * * Please keep this header. * * 2012 * / package javax.util.concurrent.profilable.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import javax.util.concurrent.profilable.LockerRoom; import javax.util.concurrent.profilable.ProfilableRunnable; import javax.util.concurrent.profilable.messenger.GraphMessenger; import net.heteroclinic.graph.Bag; import net.heteroclinic.graph.ForestMinistry; class TestBlockUnblock_blockee extends ProfilableRunnable{ public TestBlockUnblock_blockee(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } LockerRoom.samplelocks[0].lock(); } finally { LockerRoom.samplelocks[0].unlock(); } } } class TestBlockUnblock_blocker extends ProfilableRunnable{ public TestBlockUnblock_blocker(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[0].lock(); try { TimeUnit.MILLISECONDS.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } finally { LockerRoom.samplelocks[0].unlock(); } } } public class Test20121204_I { /* * @param args * @throws InterruptedException / public static void main(String[] args) throws InterruptedException { Bag.tierdistance = 10.0d; Bag.nodesize = 2.5d; Bag.nodespace = 1.3d Bag.nodesize; Bag.familydistance = 2.0d * Bag.nodespace; Bag.boderspace = 3.0d * Bag.nodespace; Bag.OneDoubleequalpixels = 15; Bag.fontsize = 14; Bag.fontwidth = 8; // not accurate. Bag.edgetrim = 1.5d; // ratio if (args.length >= 1 ) { Bag.testresultfilepath = args[0]; } else { Bag.testresultfilepath = "C:\\Users\\Graphics\\Desktop\\treetortest\\"; } Bag.testunitname = "PFLB_BLOCK_UNBLOCK_SIMPLE"; Bag.testresultfiletype = ".png"; Bag.treeinteveralinforest = 1.0d * Bag.nodespace; // first pass set Bag.forestministryusepresetgraphborder false // second pass set true, change the values with ForestMinistry.initGraphBorder Bag.forestministryusepresetgraphborder =true; if ( Bag.forestministryusepresetgraphborder ) { Bag.forestministryupdategraphborder = false; ForestMinistry.initGraphBorder(-1,0.0,0.0,0.0,0.0,0.0,0.0,41.375,29.25); } else { Bag.forestministryupdategraphborder = true; } CountDownLatch startSignal = new CountDownLatch(1); List<Future<?>> fl = new ArrayList<Future<?>>(); ExecutorService exec = Executors.newCachedThreadPool(); //TODO how can we guarantee the static locks' constructors' messages are passed? because the message queue is static. We can buffer messages even Messenger thread is not started. fl.add(exec.submit(new GraphMessenger(startSignal))); fl.add(exec.submit(new TestBlockUnblock_blocker( startSignal))); fl.add(exec.submit(new TestBlockUnblock_blockee( startSignal))); TimeUnit.MILLISECONDS.sleep(4000); exec.shutdown(); for (Future<?> f : fl) f.cancel(true); ForestMinistry.printStaticGraphBorder(); } }
	Advanced Concurrency Topic: Runtime Deadlock Detection XXIII Treetorplus3 and jdfrbeta01 Prototype no.3 A More Complex Blocker and Blockee How to: java -cp treetorplus3.jar;jdfrbeta01.jar javax.util.concurrent.profilable.test.Test20121209_BLOKER_BLOKEE_COMLEX .\ You will get the images at the folder specified. You can also try to modify this file. /* * jdfr: Java Dead-lock Free Runtime (the goal of this project) * * Author Zhikai Wang/www.heteroclinic.net * * Please keep this header. * * 2012 * / package javax.util.concurrent.profilable.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import javax.util.concurrent.profilable.LockerRoom; import javax.util.concurrent.profilable.ProfilableRunnable; import javax.util.concurrent.profilable.messenger.GraphMessenger; import net.heteroclinic.graph.Bag; import net.heteroclinic.graph.ForestMinistry; class TestBlockUnblock_blockee_complex extends ProfilableRunnable{ public TestBlockUnblock_blockee_complex(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[1].lock(); LockerRoom.samplelocks[2].lock(); try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } LockerRoom.samplelocks[0].lock(); } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[1].unlock(); LockerRoom.samplelocks[2].unlock(); } } } class TestBlockUnblock_blocker_complex extends ProfilableRunnable{ public TestBlockUnblock_blocker_complex(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[3].lock(); LockerRoom.samplelocks[4].lock(); LockerRoom.samplelocks[0].lock(); try { TimeUnit.MILLISECONDS.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[3].unlock(); LockerRoom.samplelocks[4].unlock(); } } } public class Test20121209_BLOKER_BLOKEE_COMLEX { public static void main(String[] args) throws InterruptedException { Bag.tierdistance = 10.0d; Bag.nodesize = 2.5d; Bag.nodespace = 1.3d Bag.nodesize; Bag.familydistance = 2.0d * Bag.nodespace; Bag.boderspace = 3.0d * Bag.nodespace; Bag.OneDoubleequalpixels = 15; Bag.fontsize = 14; Bag.fontwidth = 8; // not accurate. Bag.edgetrim = 1.5d; // ratio if (args.length >= 1 ) { Bag.testresultfilepath = args[0]; } else { Bag.testresultfilepath = "C:\\Users\\Graphics\\Desktop\\treetortest\\"; } Bag.testunitname = "PROFLB_BLOKER_BLOKEE_COMLEX"; Bag.testresultfiletype = ".png"; Bag.treeinteveralinforest = 1.0d * Bag.nodespace; // first pass set Bag.forestministryusepresetgraphborder false // second pass set true, change the values with ForestMinistry.initGraphBorder Bag.forestministryusepresetgraphborder =true; if ( Bag.forestministryusepresetgraphborder ) { Bag.forestministryupdategraphborder = false; ForestMinistry.initGraphBorder(-1,0.0,0.0,0.0,0.0,0.0,0.0,51.375,39.0); } else { Bag.forestministryupdategraphborder = true; } CountDownLatch startSignal = new CountDownLatch(1); List<Future<?>> fl = new ArrayList<Future<?>>(); ExecutorService exec = Executors.newCachedThreadPool(); fl.add(exec.submit(new GraphMessenger(startSignal))); fl.add(exec.submit(new TestBlockUnblock_blockee_complex( startSignal))); fl.add(exec.submit(new TestBlockUnblock_blocker_complex( startSignal))); TimeUnit.MILLISECONDS.sleep(10000); exec.shutdown(); for (Future<?> f : fl) f.cancel(true); ForestMinistry.printStaticGraphBorder(); } }
	Advanced Concurrency Topic: Runtime Deadlock Detection XXIV Treetorplus3 and jdfrbeta01 Prototype no.4 A Simple Dead-lock Profiled How to: java -cp treetorplus3.jar;jdfrbeta01.jar javax.util.concurrent.profilable.test.Test20121210_DEAD_LOCK_VISUAL .\ You will get the images at the folder specified. After the dead-lock is formed, the program will not stop unless a forced ctrl-C. The late tryer caused the dead-lock is painted by 'stop-sign' color. If you find any errors or you want to leave other comments, please send me email. You can also try to modify this file. /* * jdfr: Java Dead-lock Free Runtime (the goal of this project) * * Author Zhikai Wang/www.heteroclinic.net * * Please keep this header. * * 2012 * / package javax.util.concurrent.profilable.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import javax.util.concurrent.profilable.LockerRoom; import javax.util.concurrent.profilable.ProfilableRunnable; import javax.util.concurrent.profilable.messenger.GraphMessenger; import net.heteroclinic.graph.Bag; import net.heteroclinic.graph.ForestMinistry; class DLRunholder extends ProfilableRunnable{ public DLRunholder(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[1].lock(); LockerRoom.samplelocks[2].lock(); try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } LockerRoom.samplelocks[0].lock(); } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[1].unlock(); LockerRoom.samplelocks[2].unlock(); } } } class DLRuntryer extends ProfilableRunnable{ public DLRuntryer(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[0].lock(); LockerRoom.samplelocks[3].lock(); try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } LockerRoom.samplelocks[2].lock(); } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[3].unlock(); LockerRoom.samplelocks[2].unlock(); } } } public class Test20121210_DEAD_LOCK_VISUAL { /* * @param args * @throws InterruptedException / public static void main(String[] args) throws InterruptedException { // TODO Auto-generated method stub Bag.tierdistance = 10.0d; Bag.nodesize = 2.5d; Bag.nodespace = 1.3d Bag.nodesize; Bag.familydistance = 2.0d * Bag.nodespace; Bag.boderspace = 3.0d * Bag.nodespace; Bag.OneDoubleequalpixels = 15; Bag.fontsize = 14; Bag.fontwidth = 8; // not accurate. Bag.edgetrim = 1.5d; // ratio if (args.length >= 1 ) { Bag.testresultfilepath = args[0]; } else { Bag.testresultfilepath = "C:\\Users\\Graphics\\Desktop\\treetortest\\"; } Bag.testunitname = "DEAD_LOCK_VISUAL"; Bag.testresultfiletype = ".png"; Bag.treeinteveralinforest = 1.0d * Bag.nodespace; // first pass set Bag.forestministryusepresetgraphborder false // second pass set true, change the values with ForestMinistry.initGraphBorder Bag.forestministryusepresetgraphborder =true; if ( Bag.forestministryusepresetgraphborder ) { Bag.forestministryupdategraphborder = false; ForestMinistry.initGraphBorder(-1,0.0,0.0,0.0,0.0,0.0,0.0,51.375,39.0); } else { Bag.forestministryupdategraphborder = true; } CountDownLatch startSignal = new CountDownLatch(1); List<Future<?>> fl = new ArrayList<Future<?>>(); ExecutorService exec = Executors.newCachedThreadPool(); fl.add(exec.submit(new GraphMessenger(startSignal))); fl.add(exec.submit(new DLRuntryer( startSignal))); fl.add(exec.submit(new DLRunholder( startSignal))); TimeUnit.MILLISECONDS.sleep(20000); // when the deadlock is formed, the program will not reach here. exec.shutdown(); for (Future<?> f : fl) f.cancel(true); ForestMinistry.printStaticGraphBorder(); } } PNGs: Figure 01 Figure 02 Figure 03 Figure 04 Figure 05 Figure 06 Figure 07 Figure 08 Figure 09 Figure 10

	Advanced Concurrency Topic: Runtime Deadlock Detection XXI Treetorplus3 and jdfrbeta01 Prototype no.1 Just Lock and Unlock Now we realease Treetorplus3 treetorplus3.jar,treetorLicesnse.txt. We also release jdfrbeta01.jar. 'jdfr' stands for Java Dead-lock Free Runtime. The goal is to design a runtime that will handle general concurrency issues. In the future, we may extend to operating system design/implementation. Or it may not be necessarily to design or implement something new, because we have 'injection' technology. These goals are still far. By now, what are at our hands are four prototypes. So far, we are able to profile basic concurrency events. Please note these prototype will only under the very conditions we pre-set. What works is just what worked! Any above-mentioned goals are huge tasks beyond the limited ability of the author. I spent much time studying java.util.concurrent written by Prof. Doug Lea. It corrects some very critical mis-understandings of mine. Although I am able to build these prototypes using C, C++ etc, without Java, without open source, it won't be so fast. Eclipse Java IDE also provides great help speeding up the work. 'jdfr' is open source. The jar comes with the source code inside. The first prototype is 'Just Lock and Unlock'. How to: java -cp treetorplus3.jar;jdfrbeta01.jar javax.util.concurrent.profilable.test.Test20121201_II .\ You will get the images at the folder specified. You can also try to modify this file. /* * jdfr: Java Dead-lock Free Runtime (the goal of this project) * * Author Zhikai Wang/www.heteroclinic.net * * Please keep this header. * * 2012 * / package javax.util.concurrent.profilable.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import javax.util.concurrent.profilable.LockerRoom; import javax.util.concurrent.profilable.ProfilableRunnable; import javax.util.concurrent.profilable.locks.ProfilableReentrantLock; import javax.util.concurrent.profilable.messenger.FunctorType; import javax.util.concurrent.profilable.messenger.GraphMessenger; import net.heteroclinic.graph.Bag; import net.heteroclinic.graph.ForestMinistry; class Testrun_II extends ProfilableRunnable{ public Testrun_II(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[0].lock(); LockerRoom.samplelocks[1].lock(); LockerRoom.samplelocks[2].lock(); try { TimeUnit.MILLISECONDS.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } // catch (InterruptedException e) { // // TODO Auto-generated catch block // e.printStackTrace(); // } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[1].unlock(); LockerRoom.samplelocks[2].unlock(); } } } public class Test20121201_II { // public static ProfilableReentrantLock [] locks = // new ProfilableReentrantLock [10]; // static { // for (int i = 0; i<locks.length; i++) { // locks[i] = new ProfilableReentrantLock(); // } // } /* * @param args * @throws InterruptedException / public static void main(String[] args) throws InterruptedException { Bag.tierdistance = 10.0d; Bag.nodesize = 2.5d; Bag.nodespace = 1.3d Bag.nodesize; Bag.familydistance = 2.0d * Bag.nodespace; Bag.boderspace = 3.0d * Bag.nodespace; Bag.OneDoubleequalpixels = 15; Bag.fontsize = 14; Bag.fontwidth = 8; // not accurate. Bag.edgetrim = 1.5d; // ratio if (args.length >= 1 ) { Bag.testresultfilepath = args[0]; } else { Bag.testresultfilepath = "C:\\Users\\Graphics\\Desktop\\treetortest\\"; } Bag.testunitname = "PFLB_JUST_LOCK_UNLOCK"; Bag.testresultfiletype = ".png"; Bag.treeinteveralinforest = 1.0d * Bag.nodespace; // first pass set Bag.forestministryusepresetgraphborder false // second pass set true, change the values with ForestMinistry.initGraphBorder Bag.forestministryusepresetgraphborder =true; if ( Bag.forestministryusepresetgraphborder ) { Bag.forestministryupdategraphborder = false; ForestMinistry.initGraphBorder(-1,0.0,0.0,0.0,0.0,0.0,0.0,31.375,26.0); } else { Bag.forestministryupdategraphborder = true; } CountDownLatch startSignal = new CountDownLatch(1); List<Future<?>> fl = new ArrayList<Future<?>>(); ExecutorService exec = Executors.newCachedThreadPool(); fl.add(exec.submit(new GraphMessenger(startSignal))); fl.add(exec.submit(new Testrun_II( startSignal))); TimeUnit.MILLISECONDS.sleep(2000); exec.shutdown(); for (Future<?> f : fl) f.cancel(true); ForestMinistry.printStaticGraphBorder(); } }
	Advanced Concurrency Topic: Runtime Deadlock Detection XXII Treetorplus3 and jdfrbeta01 Prototype no.2 Simple Blocker and Blockee How to: java -cp treetorplus3.jar;jdfrbeta01.jar javax.util.concurrent.profilable.test.Test20121204_I .\ You will get the images at the folder specified. You can also try to modify this file. /* * jdfr: Java Dead-lock Free Runtime (the goal of this project) * * Author Zhikai Wang/www.heteroclinic.net * * Please keep this header. * * 2012 * / package javax.util.concurrent.profilable.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import javax.util.concurrent.profilable.LockerRoom; import javax.util.concurrent.profilable.ProfilableRunnable; import javax.util.concurrent.profilable.messenger.GraphMessenger; import net.heteroclinic.graph.Bag; import net.heteroclinic.graph.ForestMinistry; class TestBlockUnblock_blockee extends ProfilableRunnable{ public TestBlockUnblock_blockee(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } LockerRoom.samplelocks[0].lock(); } finally { LockerRoom.samplelocks[0].unlock(); } } } class TestBlockUnblock_blocker extends ProfilableRunnable{ public TestBlockUnblock_blocker(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[0].lock(); try { TimeUnit.MILLISECONDS.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } finally { LockerRoom.samplelocks[0].unlock(); } } } public class Test20121204_I { /* * @param args * @throws InterruptedException / public static void main(String[] args) throws InterruptedException { Bag.tierdistance = 10.0d; Bag.nodesize = 2.5d; Bag.nodespace = 1.3d Bag.nodesize; Bag.familydistance = 2.0d * Bag.nodespace; Bag.boderspace = 3.0d * Bag.nodespace; Bag.OneDoubleequalpixels = 15; Bag.fontsize = 14; Bag.fontwidth = 8; // not accurate. Bag.edgetrim = 1.5d; // ratio if (args.length >= 1 ) { Bag.testresultfilepath = args[0]; } else { Bag.testresultfilepath = "C:\\Users\\Graphics\\Desktop\\treetortest\\"; } Bag.testunitname = "PFLB_BLOCK_UNBLOCK_SIMPLE"; Bag.testresultfiletype = ".png"; Bag.treeinteveralinforest = 1.0d * Bag.nodespace; // first pass set Bag.forestministryusepresetgraphborder false // second pass set true, change the values with ForestMinistry.initGraphBorder Bag.forestministryusepresetgraphborder =true; if ( Bag.forestministryusepresetgraphborder ) { Bag.forestministryupdategraphborder = false; ForestMinistry.initGraphBorder(-1,0.0,0.0,0.0,0.0,0.0,0.0,41.375,29.25); } else { Bag.forestministryupdategraphborder = true; } CountDownLatch startSignal = new CountDownLatch(1); List<Future<?>> fl = new ArrayList<Future<?>>(); ExecutorService exec = Executors.newCachedThreadPool(); //TODO how can we guarantee the static locks' constructors' messages are passed? because the message queue is static. We can buffer messages even Messenger thread is not started. fl.add(exec.submit(new GraphMessenger(startSignal))); fl.add(exec.submit(new TestBlockUnblock_blocker( startSignal))); fl.add(exec.submit(new TestBlockUnblock_blockee( startSignal))); TimeUnit.MILLISECONDS.sleep(4000); exec.shutdown(); for (Future<?> f : fl) f.cancel(true); ForestMinistry.printStaticGraphBorder(); } }
	Advanced Concurrency Topic: Runtime Deadlock Detection XXIII Treetorplus3 and jdfrbeta01 Prototype no.3 A More Complex Blocker and Blockee How to: java -cp treetorplus3.jar;jdfrbeta01.jar javax.util.concurrent.profilable.test.Test20121209_BLOKER_BLOKEE_COMLEX .\ You will get the images at the folder specified. You can also try to modify this file. /* * jdfr: Java Dead-lock Free Runtime (the goal of this project) * * Author Zhikai Wang/www.heteroclinic.net * * Please keep this header. * * 2012 * / package javax.util.concurrent.profilable.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import javax.util.concurrent.profilable.LockerRoom; import javax.util.concurrent.profilable.ProfilableRunnable; import javax.util.concurrent.profilable.messenger.GraphMessenger; import net.heteroclinic.graph.Bag; import net.heteroclinic.graph.ForestMinistry; class TestBlockUnblock_blockee_complex extends ProfilableRunnable{ public TestBlockUnblock_blockee_complex(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[1].lock(); LockerRoom.samplelocks[2].lock(); try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } LockerRoom.samplelocks[0].lock(); } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[1].unlock(); LockerRoom.samplelocks[2].unlock(); } } } class TestBlockUnblock_blocker_complex extends ProfilableRunnable{ public TestBlockUnblock_blocker_complex(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[3].lock(); LockerRoom.samplelocks[4].lock(); LockerRoom.samplelocks[0].lock(); try { TimeUnit.MILLISECONDS.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[3].unlock(); LockerRoom.samplelocks[4].unlock(); } } } public class Test20121209_BLOKER_BLOKEE_COMLEX { public static void main(String[] args) throws InterruptedException { Bag.tierdistance = 10.0d; Bag.nodesize = 2.5d; Bag.nodespace = 1.3d Bag.nodesize; Bag.familydistance = 2.0d * Bag.nodespace; Bag.boderspace = 3.0d * Bag.nodespace; Bag.OneDoubleequalpixels = 15; Bag.fontsize = 14; Bag.fontwidth = 8; // not accurate. Bag.edgetrim = 1.5d; // ratio if (args.length >= 1 ) { Bag.testresultfilepath = args[0]; } else { Bag.testresultfilepath = "C:\\Users\\Graphics\\Desktop\\treetortest\\"; } Bag.testunitname = "PROFLB_BLOKER_BLOKEE_COMLEX"; Bag.testresultfiletype = ".png"; Bag.treeinteveralinforest = 1.0d * Bag.nodespace; // first pass set Bag.forestministryusepresetgraphborder false // second pass set true, change the values with ForestMinistry.initGraphBorder Bag.forestministryusepresetgraphborder =true; if ( Bag.forestministryusepresetgraphborder ) { Bag.forestministryupdategraphborder = false; ForestMinistry.initGraphBorder(-1,0.0,0.0,0.0,0.0,0.0,0.0,51.375,39.0); } else { Bag.forestministryupdategraphborder = true; } CountDownLatch startSignal = new CountDownLatch(1); List<Future<?>> fl = new ArrayList<Future<?>>(); ExecutorService exec = Executors.newCachedThreadPool(); fl.add(exec.submit(new GraphMessenger(startSignal))); fl.add(exec.submit(new TestBlockUnblock_blockee_complex( startSignal))); fl.add(exec.submit(new TestBlockUnblock_blocker_complex( startSignal))); TimeUnit.MILLISECONDS.sleep(10000); exec.shutdown(); for (Future<?> f : fl) f.cancel(true); ForestMinistry.printStaticGraphBorder(); } }
	Advanced Concurrency Topic: Runtime Deadlock Detection XXIV Treetorplus3 and jdfrbeta01 Prototype no.4 A Simple Dead-lock Profiled How to: java -cp treetorplus3.jar;jdfrbeta01.jar javax.util.concurrent.profilable.test.Test20121210_DEAD_LOCK_VISUAL .\ You will get the images at the folder specified. After the dead-lock is formed, the program will not stop unless a forced ctrl-C. The late tryer caused the dead-lock is painted by 'stop-sign' color. If you find any errors or you want to leave other comments, please send me email. You can also try to modify this file. /* * jdfr: Java Dead-lock Free Runtime (the goal of this project) * * Author Zhikai Wang/www.heteroclinic.net * * Please keep this header. * * 2012 * / package javax.util.concurrent.profilable.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import javax.util.concurrent.profilable.LockerRoom; import javax.util.concurrent.profilable.ProfilableRunnable; import javax.util.concurrent.profilable.messenger.GraphMessenger; import net.heteroclinic.graph.Bag; import net.heteroclinic.graph.ForestMinistry; class DLRunholder extends ProfilableRunnable{ public DLRunholder(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[1].lock(); LockerRoom.samplelocks[2].lock(); try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } LockerRoom.samplelocks[0].lock(); } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[1].unlock(); LockerRoom.samplelocks[2].unlock(); } } } class DLRuntryer extends ProfilableRunnable{ public DLRuntryer(CountDownLatch startsignal) { super(startsignal); } @Override public void subContract() { try { LockerRoom.samplelocks[0].lock(); LockerRoom.samplelocks[3].lock(); try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } LockerRoom.samplelocks[2].lock(); } finally { LockerRoom.samplelocks[0].unlock(); LockerRoom.samplelocks[3].unlock(); LockerRoom.samplelocks[2].unlock(); } } } public class Test20121210_DEAD_LOCK_VISUAL { /* * @param args * @throws InterruptedException / public static void main(String[] args) throws InterruptedException { // TODO Auto-generated method stub Bag.tierdistance = 10.0d; Bag.nodesize = 2.5d; Bag.nodespace = 1.3d Bag.nodesize; Bag.familydistance = 2.0d * Bag.nodespace; Bag.boderspace = 3.0d * Bag.nodespace; Bag.OneDoubleequalpixels = 15; Bag.fontsize = 14; Bag.fontwidth = 8; // not accurate. Bag.edgetrim = 1.5d; // ratio if (args.length >= 1 ) { Bag.testresultfilepath = args[0]; } else { Bag.testresultfilepath = "C:\\Users\\Graphics\\Desktop\\treetortest\\"; } Bag.testunitname = "DEAD_LOCK_VISUAL"; Bag.testresultfiletype = ".png"; Bag.treeinteveralinforest = 1.0d * Bag.nodespace; // first pass set Bag.forestministryusepresetgraphborder false // second pass set true, change the values with ForestMinistry.initGraphBorder Bag.forestministryusepresetgraphborder =true; if ( Bag.forestministryusepresetgraphborder ) { Bag.forestministryupdategraphborder = false; ForestMinistry.initGraphBorder(-1,0.0,0.0,0.0,0.0,0.0,0.0,51.375,39.0); } else { Bag.forestministryupdategraphborder = true; } CountDownLatch startSignal = new CountDownLatch(1); List<Future<?>> fl = new ArrayList<Future<?>>(); ExecutorService exec = Executors.newCachedThreadPool(); fl.add(exec.submit(new GraphMessenger(startSignal))); fl.add(exec.submit(new DLRuntryer( startSignal))); fl.add(exec.submit(new DLRunholder( startSignal))); TimeUnit.MILLISECONDS.sleep(20000); // when the deadlock is formed, the program will not reach here. exec.shutdown(); for (Future<?> f : fl) f.cancel(true); ForestMinistry.printStaticGraphBorder(); } } PNGs: Figure 01 Figure 02 Figure 03 Figure 04 Figure 05 Figure 06 Figure 07 Figure 08 Figure 09 Figure 10