JPLTest.java

Go to the documentation of this file.

/*
 * JPLTest.java
 * JUnit based test
 *
 * Created on 13 February 2006, 11:31
 */
package jpl.test;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.logging.Logger;
import junit.framework.*;
import jpl.*;

public class JPLTest extends TestCase {
        // private static final Logger  logger  = Logger.getLogger(JPLTest.class.getName());
        private CountDownLatch  latch;
        public JPLTest(String testName) {
                super(testName);
        }
        protected void setUp() throws Exception {
                /* 
                 * Prolog file can be an empty file.  The JVM seems to crash with a
                 * SIGSEGV if you don't consult a file prior to interacting with JPL.
                 
                 final String prologFile = "jpl/test/test.pl"; // was "/home/rick/temp/test.pl";
                 System.out.println("prolog file is: " + prologFile);
                 String qString = "consult('" + prologFile + "')";
                 System.out.println("about to: " + qString);
                 Query query = new Query(qString);
                 System.out.println("Generated Query: " + query);
                 if (!query.hasSolution()) {
                 System.out.println(qString + " failed");
                 fail("Failed to consult prolog file.");
                 }
                 
                (new Query("true")).hasSolution();
                 */
        }
        public void testThreadedAdds() {
                latch = new CountDownLatch(4);
                final AddWithThreads[] addTasks = { new AddWithThreads("a", latch), new AddWithThreads("b", latch), new AddWithThreads("c", latch), new AddWithThreads("d", latch) };
                // System.out.println("Starting threads...");
                for (int i = 0; i < addTasks.length; i++) {
                        addTasks[i].start();
                }
                try {
                        // System.out.println("Latch is waiting");
                        assertTrue("Timed out waiting for action to execute", latch.await(20, TimeUnit.SECONDS));
                        // System.out.println("Latch has been flipped");
                } catch (final InterruptedException e) {
                        fail("Waiting thread was interrupted: " + e);
                }
                for (int i = 0; i < AddWithThreads.REPS; i++) {
                        for (int j = 0; j < addTasks.length; j++) {
                                Query query = new Query(addTasks[j].getNamespace() + "(test('" + i + "'))");
                                // System.out.println("query: " + query);
                                boolean ret = query.hasMoreElements();
                                query.close();
                        }
                }
        }
}

class AddWithThreads extends Thread {
        private final CountDownLatch    latch;
        private final String                    namespace;
        private static final Logger             logger  = Logger.getLogger(JPLTest.class.getName());
        public static final int                 REPS    = 2000; // was 200
        public AddWithThreads(final String namespace, final CountDownLatch latch) {
                this.latch = latch;
                this.namespace = namespace;
                setName("namespace" + namespace); //set thread name for debugging
        }
        public String getNamespace() {
                return namespace;
        }
        public void run() {
                for (int i = 0; i < REPS; i++) {
                        // System.out.println("Asserting test('" + i + "')");
                        Query queryA = new Query("assert(" + namespace + "(test('" + i + "')))");
                        Thread.yield();
                        // System.out.println("adding query: " + queryA);
                        boolean retA = queryA.hasMoreElements();
                        queryA.close();
                }
                latch.countDown();
        }
}

---

jpl
Author(s): Lorenz Moesenlechner
autogenerated on Fri Jan 11 09:40:29 2013