一个类不实现方法的接口

Question

我有一个生产者，它获取数据A，产生数据B，并将其发送出去

    public interface Producer<T>{
        void produce(T data);
        void flush();
    }

    public class DataBaseProducer implements Producer<String>{
        List<String> producedData = new ArrayList<>();

        // create data
        public void produce(String data){
            producedData.add(transformData(data));
        }

       // send created data
        public void flush(){
           sendDataToDatabase(producedData);
        }
    }

   
   public class MessageProducer implements Producer<String>{
        public void produce(String data){
           String line =transformData(data)
           sendDataToMessageQueue(line);
        }

        public void flush(){
        }
   }

public static void main(String[] args) {
    // get producer
    Producer producer = getProducer(producerName)
    BufferedReader reader;
    try {
        reader = new BufferedReader(new FileReader(file..));
        String line = reader.readLine();
        while (line != null) {
            producer.produce(line)
            line = reader.readLine();
        }
        reader.close();
        producer.flush()
    } catch (IOException e) {
        e.printStackTrace();
    }
}

为了证明我的问题，想象一下我有像上面这样的制作人。一个加载所有数据，然后在完成后立即批量发送，第二个立即发送数据（因此它不批量发送数据，但每当有新数据时，createdit立即发送）

大多数生产者会在每加载一个数据之后发送数据，但很少有人会马上发送。如果生产者立即发送数据，则flush()方法将保持为空。然而，这似乎是一种糟糕的做法，可能违反了一些OOP原则。对此，正确的实施方式是什么？

谢谢你的回答！

Answer 1

在我看来，并且在检查了main()代码之后，我认为MessageProducer并不是真正的生产者，因为Producer方法实际上是同时生成和刷新。

但是，由于您似乎需要以相同的方式独立地对待从getProducer(producerName)获得的内容，那么您可以做的事情如下所示：

public class MessageProducer implements Producer<String> {

    private boolean flushNeeded;
    private String line;

    public void produce(String data){
       line =transformData(data)
       flushNeeded = true;
       flush();
    }

    public void flush(){
        if (flushNeeded) {
            sendDataToMessageQueue(line);
            flushNeeded = false;
        }
    }
 }

但在我的浅见中，这与让flush()实现为空并没有什么显著的区别，如果不是为了让代码对读者更清楚一点的话（读取一个空的flush()实际上可能会错误地认为您的实现从未刷新，而它确实刷新了，但只是进入了produce方法）。