Java（Android）中的优先ThreadPoolExecutor

Question

我正在尝试使ThreadPoolExecutor具有优先权。所以我定义一个

private static ThreadPoolExecutor threadpool = new ThreadPoolExecutor(30, MAXPOOL,  MAXPOOL, TimeUnit.SECONDS,  
     queue, new mThreadFactory());

因此，关键是现在的队列引用。但是当我声明：

static PriorityBlockingQueue<mDownloadThread> queue=new PriorityBlockingQueue<mDownloadThread>(MAXPOOL,new DownloadThreadComparator());

编译器在第一行给出错误：
构造函数ThreadPoolExecutor（int，int，int，TimeUnit，PriorityBlockingQueue，FileAccess.mThreadFactory）是未定义的
，只有一个快速修复程序： 将’queue’的类型更改为BlockingQueue 。您能帮助我了解问题所在吗？

谢谢

附加信息：

为了比较可运行对象，我实现了以下类

class mDownloadThread implements Runnable{      
    private Runnable mRunnable;     
    private int priority;       
    mDownloadThread(Runnable runnable){
        mRunnable=runnable;         
    }

    @Override
    public void run() {
        mRunnable.run();        
    }

    public int getPriority() {
        return priority;
    }

    public void setPriority(int priority) {
        this.priority = priority;
    }       
}

比较器：

class DownloadThreadComparator implements Comparator<mDownloadThread>{
    @Override
    public int compare(mDownloadThread arg0, mDownloadThread arg1) {

    if (arg0==null && arg1==null){
        return 0;
    } else if (arg0==null){
        return -1;
    } else if (arg1==null){
        return 1;
    }
    return arg0.getPriority()-arg1.getPriority();

    }

}

Answer 1

ThreadPoolExecutor构造函数接受BlockingQueue<Runnable>而不是BlockingQueue<? extends Runnable>，因此您不能传递给它的PriorityBlockingQueue<mDownloadThread>实例。

您可以将的类型更改queue为PriorityBlockingQueue<Runnable>，但是在这种情况下，如果不将其Comparator<mDownloadThread>强制转换为compare方法，就无法实现。

另一种解决方案是绕过泛型类型检查，但是这将是你的责任，只提交的情况下mDownloadThread，以execute方法：

static ThreadPoolExecutor threadpool = new ThreadPoolExecutor(30, MAXPOOL, 
        MAXPOOL, TimeUnit.SECONDS, (PriorityBlockingQueue) queue, new mThreadFactory());