CounterJvn2.java

Go to the documentation of this file.

package counter;

import jvn.JvnException;
import jvn.JvnServerImpl;

public class CounterJvn2 {

        public static void main(String[] args) {
                try {
                        // initialize JVN
                        JvnServerImpl js = JvnServerImpl.jvnGetServer();
                        
                        if (js == null) {
                                System.out.println("Counter stress test problem : cannot create server!");
                        }
                        else {
                                // look up the IRC object in the JVN server
                                // if not found, create it, and register it in the JVN server
                                
                                JvnIntegerWrapper jo = (JvnIntegerWrapper)(js.jvnLookupObject("Counter",JvnIntegerWrapper.class));
                                if (jo == null) {
                                        jo = new JvnIntegerWrapper();
                                        // after creation, I have a write lock on the object
                                        jo.jvnUnLock();
                                        js.jvnRegisterObject("Counter", jo);
                                }
                                while(true) {
                                        try {
                                                int number = jo.read();
                                                System.out.println("Current number is "+number+", next number shall be "+(++number));
                                                jo.write(number);
                                        } catch (JvnException je) {
                                                System.out.println("Counter stress test problem : " + je.getMessage());
                                        }
                                }
                        }
                } catch (JvnException je) {
                        System.out.println("Counter stress test problem : " + je.getMessage());
                }
        }
}

---