package com.ikea.vmob.util;

import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;

public class BoundedLIFOExecutor extends ThreadPoolExecutor
{
  public BoundedLIFOExecutor(int paramInt, ThreadFactory paramThreadFactory)
  {
    super(paramInt, paramInt, 50L, TimeUnit.SECONDS, new FixedSizeLIFOQueue(10), paramThreadFactory);
  }

  private static class FixedSizeLIFOQueue extends LinkedBlockingDeque<Runnable>
  {
    private static final long serialVersionUID = -220022960932112863L;

    public FixedSizeLIFOQueue(int paramInt)
    {
      super();
    }

    public boolean offer(Runnable paramRunnable)
    {
      try
      {
        this.lock.lock();
        int i = size();
        int j = this.capacity;
        if (i == j);
        try
        {
          removeLast();
          label31: boolean bool = super.offerFirst(paramRunnable);
          this.lock.unlock();
          return bool;
        }
        catch (Exception localException)
        {
          break label31;
        }
      }
      finally
      {
      }
    }
  }
}

/* Location:           C:\Documents and Settings\Cesar Cabello Cea\Mis documentos\Downloads\apk-downloader\com.ikea.kompis-6_dex2jar.jar
 * Qualified Name:     com.ikea.vmob.util.BoundedLIFOExecutor
 * JD-Core Version:    0.6.2
 */