simulating Canal system with concurrent programming (java)