Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-1637

AsyncStore.enqueue() throws 'CacheException: Unable to enqueue asynchronous task' Instead of blocking when the queue is full

    XMLWordPrintable

Details

    Description

      Documentation http://docs.jboss.org/infinispan/5.1/apidocs/config.html#ce_loader_async :

      "modificationQueueSize int 1024 Sets the size of the modification queue for the async store. If updates are made at a rate that is faster than the underlying cache store can process this queue, then the async store behaves like a synchronous store for that period, blocking until the queue can accept more elements. (Javadoc)"

      However the async store doesn't "behaves like synchronous [...] blocking until the queue can accept more elements" because AsyncStore.enqueue() calls

      changesDeque.add(mod);

      But I guess it should call put() to wait queue to accept more elements.

      Attachments

        Activity

          People

            manik_jira Manik Surtani (Inactive)
            andpushkin Andrew Pushkin (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - 2 hours
                2h
                Remaining:
                Remaining Estimate - 2 hours
                2h
                Logged:
                Time Spent - Not Specified
                Not Specified