Scheduled queries

gistfile1.java

    private void runSingleThread(ScheduledExecutorService scheduler, final AllTypes allTypes) {
        testRealm.beginTransaction();
        allTypes.setColumnLong(1);
        testRealm.commitTransaction();
        Log.d("REALM", "runSingleThread");

        scheduler.schedule(new Runnable() {
            @Override
            public void run() {
                Log.d("REALM", "run");
                Realm realm = Realm.getInstance(getContext());
                RealmResults<AllTypes> allTypeses = realm.where(AllTypes.class).equalTo(FIELD_LONG, 1).findAll();
                Log.d("REALM", "size " + allTypeses.size());
                realm.close();
            }
        }, 5, TimeUnit.SECONDS);
    }

    public void testSingleThread() {
        ScheduledExecutorService scheduler;
        scheduler = newSingleThreadScheduledExecutor();

        testRealm.beginTransaction();
        testRealm.clear(AllTypes.class);
        testRealm.commitTransaction();

        testRealm.beginTransaction();
        AllTypes allTypes1 = testRealm.createObject(AllTypes.class);
        AllTypes allTypes2 = testRealm.createObject(AllTypes.class);
        AllTypes allTypes3 = testRealm.createObject(AllTypes.class);
        testRealm.commitTransaction();

        runSingleThread(scheduler, allTypes1);
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            fail();
        }

        runSingleThread(scheduler, allTypes2);
        runSingleThread(scheduler, allTypes3);
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            fail();
        }
    }