Java ResultSet in BlockingQueue

I trying to write some blob from database to disk by passing an InputStream object to the queue. It creates the file with size 0. When I have tried write the InputStream to the disk without using a BlockingQueue, it worked without problem. Can you help me? My code is like below:

public class ExtractPicture implements Runnable{
    private BlockingQueue<InputStream> queue;
    public ExtractPicture(BlockingQueue<InputStream> queue){
        this.queue = queue;
    }    
    @Override
    public void run() {
        try(Connection conn = new DatabaseConnection().getConnection();
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("select mypicture from testpicture")){            
            while(rs.next()){
                queue.put(rs.getBinaryStream("mypicture"));
            }  
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}
class Consumer implements Runnable{
    private BlockingQueue<InputStream> queue;
    public Consumer(BlockingQueue<InputStream> queue){
        this.queue = queue;
    }
    @Override
    public void run() {
        try{            
            int z = 0;
            InputStream is = null;
//            (is = queue.take()) != null
            while((is = queue.take()) != null){                
                System.out.println("consumer aa" + is.toString());
                writeToDisk(is, "c:\\temp\\p" + z + ".jpeg");
                z++;
            }
            is.close();
        }catch(Exception e){
            e.printStackTrace();
        } 
    }
   private void writeToDisk(InputStream is, String fna){
       OutputStream f = null;
        try {
            f = new FileOutputStream(new File(fna));
            int c = 0;
            while((c = is.read()) > -1){
                f.write(c);
            }
        } catch (FileNotFoundException ex) {
            ex.printStackTrace();
        } catch (IOException ex) {

        } finally {
            try {
                f.close();
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
   }
}
class RunService{
     public static void main(String[] args) {
        BlockingQueue<InputStream> queue = new ArrayBlockingQueue(10);
        ExtractPicture ep = new ExtractPicture(queue);
        Consumer c = new Consumer(queue);
        new Thread(ep).start();
        new Thread(c).start();
    }    
}

Copyright License：
Author:「coco」,Reproduced under the CC 4.0 BY-SA copyright license with link to original source & disclaimer.
Link to：https://stackoverflow.com/questions/28195103/java-resultset-in-blockingqueue