取消()试图取消任务的ThreadPoolExecutor的Android不工作(cancel()

2019-10-22 06:29发布

我有一个提交的任务到一些下载ThreadPoolExecutor 。 现在,我创建这个ThreadPoolExecutor在扩展全局类Application 。 我存储在IDS一个HashMap所有提交的任务。

我有一个片段的列表视图。 该列表视图项包含暂停和恢复按钮。 当我点击列表中的项目本身,下载FutureTask提交给全局池执行。 现在,当我点击列表视图项目的暂停按钮,我想要那个特定的任务暂停。

我有onClick暂停按钮在我的列表视图中的自定义适配器方法。 所以,当我按一下按钮,在我的适配器类,我得到有关的名称列表项目的未来任务,然后做.cancel() 当我检查isCancelled()值,则返回true 。 这意味着任务已被取消,但我的下载仍然运行和文件被完全下载。 我该如何解决这个问题? 任何帮助,将不胜感激。

PS:我也曾尝试提交与运行的线程作为参数传递给执行人通过。 然后,我会得到它的名字(使用的自定义线程ThreadFactory与名称返回线程),然后调用thread.wait()直到恢复再次按下按钮。 也不行!

下面是示例代码:

我GlobalState类:

    public class GlobalState extends Application{

        HashMap<String, Future<?>> futureMapMain = new HashMap<String, Future<?>>();

        ThreadPoolExecutor mainExec = new ThreadPoolExecutor(2, 2, 2000, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(), new YourThreadFactory());

        public void submitTaskMain(String name, FutureTask<String> task){
            Future<?> longRunningTaskFuture = mainExec.submit(task);
            futureMapMain.put(name, longRunningTaskFuture);
        }

        public void cancelTaskMain(String name){
            futureMapMain.get(name).cancel(true);
            Log.e("Global State", "task cancelled?: " + futureMapMain.get(name).isCancelled());
            futureMapMain.remove(name);
        }

public void pauseTaskMain(String name){
        paused = true;
        while(paused==true){
        try {
            synchronized(futureMapMain.get(name)){
                futureMapMain.get(name).wait();
            }
        //  Thread.sleep(2000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        }
    }

    public void resumeTaskMain(String name){
        paused = false;
        synchronized(futureMapMain.get(name)){
            futureMapMain.get(name).notify();
        }
    }

        public HashMap<String, Future<?>> getFutureMap(){
            return futureMapMain;
        }

        public ThreadPoolExecutor getMainExeutor(){
            return mainExec;
        }

        public class YourThreadFactory implements ThreadFactory {
            public Thread newThread(Runnable r) {
                return new Thread(r, gettName());
            }
        }
    }

这是我的片段类里面写我的下载方法。 获取列表项点击执行:

public void abDownloadTask(){
    FutureTask<String> fTask = new FutureTask<String>(new Callable<String>() {

        @Override
        public String call() throws Exception {
            // TODO Auto-generated method stub
            for(something) {
                /* DOES SOME DOWNLOAD USING url.getcontent() with different urls in a loop and stores files to sd card. */
            }
        }
    }

    mainGs = (GlobalState) getActivity().getApplication();
    mainExec = mainGs.getMainExeutor();
    mainGs.settName(somenameforThread);
    mainGs.submitTaskMain(someNameforThread, fTask);    
}

内暂停按钮的onclick我的自定义列表适配器代码:

    Runnable runnable = new Runnable() {
            @Override
            public void run() {
                // TODO Auto-generated method stub

                                    needToPause = true;
globalstate.pauseTaskMain(threadname);
            }
        }

其实我更喜欢暂停和恢复使用的wait(),我的任务或类似的东西,而不是完全取消任务。 任何帮助,将不胜感激。 谢谢!

文章来源: cancel() not working while trying to cancel tasks in ThreadPoolExecutor Android