Realm-java: java.util.concurrent.RejectedExecutionException while executing the transaction

Created on 7 Mar 2016 · 13Comments · Source: realm/realm-java

java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@3d35e112 rejected from io.realm.internal.async.RealmThreadPoolExecutor@207080e3[Running, pool size = 5, active threads = 5, queued tasks = 100, completed tasks = 3637]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2011)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:793)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1339)
at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:81)
at io.realm.internal.async.RealmThreadPoolExecutor.submit(RealmThreadPoolExecutor.java:63)
at io.realm.Realm.executeTransaction(Realm.java:1091)

T-Help

Source

shashank090789

👍1

Most helpful comment

Instead of doing:

      for (int i = 0; i < size(); i++) {
         realm.executeTransaction(..., null);
      }

You should do

  realm.executeTransaction(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
      for (int i = 0; i < size(); i++) {
         // insert data
      }
    }
  }), null);

The later is also more efficient.

cmelchior on 7 Mar 2016

👍2 ❤1

All 13 comments

Hi @shashank090789 You are getting that exception because for some reason there is 100 queued transactions? Are you somehow creating transactions in a loop?

cmelchior on 7 Mar 2016

yes I have 96 rows and and inserting them using transaction

shashank090789 on 7 Mar 2016

Instead of doing:

      for (int i = 0; i < size(); i++) {
         realm.executeTransaction(..., null);
      }

You should do

  realm.executeTransaction(new Realm.Transaction() {
    @Override
    public void execute(Realm realm) {
      for (int i = 0; i < size(); i++) {
         // insert data
      }
    }
  }), null);

The later is also more efficient.

cmelchior on 7 Mar 2016

👍2 ❤1

I am using the same, but I am getting each row one by one from API so for each row following code is running

    realm.executeTransaction(new Realm.Transaction() {
        @Override
        public void execute(Realm bgRealm) {
          /// inserting data
        }
    }, new Realm.Transaction.Callback() {
        @Override
        public void onSuccess() {

            }
        }

        @Override
        public void onError(Exception e) {
            // transaction is automatically rolled-back, do any cleanup here
        }
    });

shashank090789 on 7 Mar 2016

@shashank090789 Did you get the data for each row from the API in a background thread? In that case you don't have to use asyc transaction to make it more complex, just use the sync transaction write them one by one.

beeender on 8 Mar 2016

👍1

Hi @shashank090789
Did you mange to solve it using the above?

cmelchior on 10 Mar 2016

Hi @cmelchior
no
I am getting data one one by from BLE device which is not is background thread (in broadcast receiver)

shashank090789 on 10 Mar 2016

@shashank090789 In that case, i suggest you to cache the 96 rows and write them in on async transaction. Or maybe there are some difficulties for this approach like the there is no end point of the broadcast?

beeender on 10 Mar 2016

@shashank090789 Did you manage to solve this issue? Can we close it?

beeender on 16 Mar 2016

I will check it and let you know if further get the same issue

shashank090789 on 18 Mar 2016

Thank you. We will wait a bit for your answer before closing this issue.