[HAMA-526] Multi-threaded vertex processing

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: bsp core, graph
• Assignee: Edward J. Yoon
• Reporter: Edward J. Yoon
• Created: 05/Mar/12 06:08
• Updated: 22/Apr/15 00:01
• Resolved: 22/Apr/15 00:01

Description

  public void bsp(BSPPeer peer) throws IOException, SyncException,
      InterruptedException {
 
      ...
      while (updated && iteration < maxIteration) {
        peer.sync();
        ...


        for (Map.Entry<String, LinkedList<Writable>> e : msgMap.entrySet()) {
          if (e.getValue().size() > 0) {
            vertices.get(e.getKey()).compute(e.getValue().iterator());
          }
        }

      ...
      }

Above code will run Vertex sequentially. Do you think we can run Vertex processing concurrently using multi-threads?

Then what's the advantages or disadvantages of using multi-threading?