流水线中的Java

Question

我有6个功能：

• 取操作
• 解码
• 取操作数
• 执行
• 回写
• updatepc

每个给输入到另一个。我想同时执行它们，即流水线。

如何做到这一点？

Answer 1

为实现Runnable的每个管道组件创建一个类。给每个组件一个ConcurrentLinkedQueue来保存要处理的数据;每个组件都会在无限循环（在其run（）方法）中轮询该队列，并在数据处理完成后对其进行处理。每个前面的组件都会将其输出添加到下一个组件的队列中。现在将每个可运行的代码分配给一个线程，启动线程并开始将数据提供给第一个组件的队列。

如果一个组件发现它的队列是空的，那么你可能想让它睡半秒钟左右。

您可能还想为每个将在run（）方法中跳出无限循环的组件添加一个cancel（）方法。

public class Decode implements Runnable { 
    private boolean cancel = false; 
    private ConcurrentLinkedQueue<Data> queue = new ConcurrentLinkedQueue<>(); 
    private FetchOperands nextComponent; 

    public void run() { 
     while(!cancel) { 
      Data data = queue.poll(); 
      if(data != null) { 
       ... 
       nextComponent.enqueue(data); 
      } else (Thread.sleep(500); 
     } 
    } 

    public void enqueue(Data data) { 
     queue.offer(data); 
    } 

    public void cancel() { 
     cancel = true; 
    } 

    public void setFetchOperands(FetchOperands nextComponent) { 
     this.nextComponent = nextComponent; 
    } 
} 

public class Main implements Runnable { 
    public void run() { 
     Decode decode = new Decode(); 
     FetchOperands fetchOperands = new FetchOperands(); 
     decode.setFetchOperands(fetchOperands); 
     Thread t1 = new Thread(decode); 
     Thread t2 = new Thread(fetchOperands); 
     t1.start(); 
     t2.start(); 
     t1.join(); 
     t2.join(); 
    } 
} 

Answer 2

Pipeline Pattern

管道模式是在将问题分为较小 可重复使用的代码组件有帮助的。这是一种简单但功能强大的结构 模式，可将复杂的逻辑组织成更小的可重用组件，可独立添加/删除/修改。

Answer 3

为了提高在@Zim-Zam O'Pootertoot's answer，而不是有一点点你的组件睡眠时有没有要处理，你可以有它wait()，然后调用notify()只要你将它传递的东西来处理。