6

サーバーから取得する画像が多数あり、他の画像よりも優先度の高い画像を取得したいので、実装ThreadPoolExecutorする a を返す独自のものFutureTaskを実装しComparableましたが、機能していないようです。タスクは、キューに追加した順序で多かれ少なかれ処理されます。BlockingQueuemyの をデバッグしたところ、myを優先度の高いものThreadPoolExecutorに追加すると、キューの一番上に移動されないことがわかりました。Runnableここにコードがあります

public class PriorityThreadPoolExecutor extends ThreadPoolExecutor {

    public PriorityThreadPoolExecutor(int corePoolSize, int maximumPoolSize,
            long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }

    protected <T> RunnableFuture<T> newTaskForValue(Runnable runnable, T value) {
        return new ComparableFutureTask<T>(runnable, value);
    }

    protected class ComparableFutureTask<T> 
    extends FutureTask<T> implements Comparable<ComparableFutureTask<T>> {

        private Object object;

        public ComparableFutureTask(Runnable runnable, T result) {
            super(runnable, result);
            object = runnable;
        }

        @Override
        @SuppressWarnings({ "unchecked", "rawtypes" })
        public int compareTo(ComparableFutureTask<T> o) {
            if (this == o) {
                return 0;
            }
            if (o == null) {
                return -1; // this has higher priority than null
            }
            if (object != null && o.object != null) {
                if (object.getClass().equals(o.object.getClass())) {
                    if (object instanceof Comparable) {
                        return ((Comparable) object).compareTo(o.object);
                    }
                }
            }
            return 0;
        }
    }

}

そして、次の方法でタスクをプールに追加します。

public BitmapLoader(Context context){
        mThreadPoolExecutor = new PriorityThreadPoolExecutor(10, Integer.MAX_VALUE,//corepool and maxpool
                1L, TimeUnit.SECONDS,//keep alive idle threads
                new PriorityBlockingQueue<Runnable>());//priority queue for jobs
    }

public void queuePhoto(String url, ImageView imageView, int priority) {     
    BitmapToLoad p = new BitmapToLoad(url, imageView, priority);
    final RunnableFuture<Object> futureTask = 
            mThreadPoolExecutor.newTaskForValue(new BitmapLoaderRunnable(p), null);
    Log.d("BitmapLoader", "Scheduling job with priority " + priority);
    mThreadPoolExecutor.execute(futureTask);
}

私のBitmapLoaderRunnable実装Comparableと、メソッドをデバッグするときにcompareTo呼び出されます。私は何を間違っていますか？ありがとう

編集：以下は私のランナブルのコードです

private class BitmapLoaderRunnable implements Runnable, Comparable<BitmapLoaderRunnable> {
        private BitmapToLoad bitmapToLoad;

        public BitmapLoaderRunnable(BitmapToLoad bitmap) {
            this.bitmapToLoad = bitmap;
        }

        @Override
        public void run() {
            try{
                if(imageViewReused(bitmapToLoad))
                    return;
                Thread.sleep(1000);
                Bitmap bmp = getBitmap(bitmapToLoad.url);
                BitmapCache.put(bitmapToLoad.url, bmp);
                if(imageViewReused(bitmapToLoad))
                    return;
                BitmapDisplayer bd = new BitmapDisplayer(bmp, bitmapToLoad);
                mHandler.post(bd);
            } catch(Throwable th){
                th.printStackTrace();
            }
        }

        @Override
        public int compareTo(BitmapLoaderRunnable other) {
            return this.bitmapToLoad.priority - other.bitmapToLoad.priority;
        }
    }
4

1 に答える 1

8

a の先頭はPriorityQueue最小要素です。したがって、最初に最高の優先度が必要な場合は、比較を逆にする必要があります。

    @Override
    public int compareTo(BitmapLoaderRunnable other) {
        return other.bitmapToLoad.priority - this.bitmapToLoad.priority;
    }
于 2013-04-26T02:26:24.263 に答える