Загрузка данных с удалённого сервера

URLConnection conection = url.openConnection(); conection.connect();
InputStream input = new BufferedInputStream(url.openStream(), 8192);
OutputStream output = new FileOutputStream(file);

public class DownloadThread implements Runnable {
 
    private String url;
    private String targetCacheFolder;
 
    public DownloadThread(String url, String targetCacheFolder) {
        this.url = url;
        this.targetCacheFolder = targetCacheFolder;
    }
 
    @Override
    public void run() {
        //TODO download image from url
    }
}

import android.util.Log;
 
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
 
public class DownloadManager {
 
    private static String cacheFolder;
    private static BlockingQueue<String> blockingQueue = new LinkedBlockingQueue<>();
    private static Thread consumerThread;
    private static ExecutorService executorService = Executors.newFixedThreadPool(10);
 
    public static void init(String cacheFolder) {
        DownloadManager.cacheFolder = cacheFolder;
        consumerThread = new Thread(new ConsumerRunnable());
        consumerThread.start();
    }
 
    public static synchronized void stop() {
        if (consumerThread != null && !consumerThread.isInterrupted()) {
            consumerThread.interrupt();
        }
        if (executorService != null && !executorService.isShutdown()) {
            executorService.shutdownNow();
        }
    }
 
    public static void addUrl(String url) {
        try {
            blockingQueue.put(url);
        } catch (InterruptedException e) {
            Log.e("DownloadManager", "Unable to add new url", e);
        }
    }
 
    private static class ConsumerRunnable implements Runnable {
 
        @Override
        public void run() {
            while (true) {
                try {
                    String take = blockingQueue.take();
                    executorService.execute(new DownloadThread(take, cacheFolder));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
 
 
}