Come posso rendere compatibile il mio codice generico con questa firma del metodo?

Question

Ho una variazione del seguente codice:

package com.test.package; 

import java.util.concurrent.BlockingQueue; 
import java.util.concurrent.PriorityBlockingQueue; 
import java.util.concurrent.ThreadPoolExecutor; 
import java.util.concurrent.TimeUnit; 

public class TestClass { 

    public static class MyRunnable implements Runnable { 

     @Override 
     public void run() { 
      System.out.println("Called"); 
     } 

    } 

    public void method() { 
     PriorityBlockingQueue<MyRunnable> queue = new PriorityBlockingQueue<MyRunnable>(); 
     method2(queue); 
    } 

    public void method2(BlockingQueue<? extends Runnable> queue) { 
     System.out.println(queue); 

     // Getting error here because BlockingQueue<? extends Runnable> is not a 
     // subtype of BlockingQueue<Runnable>. 
     ThreadPoolExecutor threadPool = new ThreadPoolExecutor(200, 200, 0L, 
      TimeUnit.MILLISECONDS, queue); 
    } 
} 

E come potete vedere, la mia coda non è compatibile con il costruttore ThreadPoolExecutor. C'è un modo per ovviare a questo rispetto a trasmettere la mia coda a (BlockingQueue<Runnable>)? Ovviamente non posso applicare la libreria standard Java.

Answer 1

No, e non si dovrebbe.

Il tuo BlockingQueue<MyRunnable> dovrebbe, ovviamente, contenere solo MyRunnable s. Ma lo ThreadPoolExecutor può inviare arbitrariamente attività alla coda che gli viene assegnata: vedere execute(Runnable command).

Se ciò si verifica, è possibile che un'istanza non sia MyRunnable nella coda. Quindi si tenta di eseguire il polling dal proprio riferimento di quella coda (digitata come BlockingQueue<MyRunnable>) e ottenere uno ClassCastException.

semplice esempio:

PriorityBlockingQueue<MyRunnable> queue = new PriorityBlockingQueue<>(); 
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(200, 200, 0L, 
     TimeUnit.MILLISECONDS, queue); 
threadPool.execute(new WhateverRunnable()); 
MyRunnable myRunnable = queue.poll(); // this could throw ClassCastException 

Il codice qui sopra un'eccezione se l'queue.poll() accade prima che il pool di thread ha avuto la possibilità di annullare l'accodamento l'istanza WhateverRunnable.