Examples of org.graphstream.stream.thread.ThreadProxyPipe

org.graphstream.stream.thread.ThreadProxyPipe
Filter that allows to pass graph events between two threads without explicit synchronization.
This filter allows to register it as an output for some source of events in a source thread (hereafter called the input thread) and to register listening outputs in a destination thread (hereafter called the sink thread).
```
 | Source ---> ThreadProxyFilter ----> Sink Thread 1             |              Thread 2 | 
```
In other words, this class allows to listen in a sink thread graph events that are produced in another source thread without any explicit synchronization on the source of events.

The only restriction is that the sink thread must regularly call the {@link #pump()} method to dispatch events coming from the source to all sinksregistered (see the explanation in {@link org.graphstream.stream.ProxyPipe}).

You can register any kind of input as source of event, but if the input is a graph, then you can choose to "replay" all the content of the graph so that at the other end of the filter, all outputs receive the complete content of the graph. This is the default behavior if this filter is constructed with a graph as input.

   * New proxy pipe on events coming from the viewer through a thread.
   * 
   * @return The new proxy pipe.
   */
  public ProxyPipe newThreadProxyOnGraphicGraph() {
    ThreadProxyPipe tpp = new ThreadProxyPipe();
    tpp.init(graph);
    return tpp;
  }

View Full Code Here

   * New viewer pipe on the events coming from the viewer through a thread.
   * 
   * @return The new viewer pipe.
   */
  public ViewerPipe newViewerPipe() {
    ThreadProxyPipe tpp = new ThreadProxyPipe();
    tpp.init(graph, false);


    enableXYZfeedback(true);


    return new ViewerPipe(String.format("viewer_%d",
        (int) (Math.random() * 10000)), tpp);

View Full Code Here


  /* (non-Javadoc)
   * @see org.graphstream.stream.netstream.NetStreamDecoder#getStream(java.lang.String)
   */
  public synchronized ThreadProxyPipe getStream(String name) {
    ThreadProxyPipe s = streams.get(name);
    if (s == null) {
      s = new ThreadProxyPipe();
      streams.put(name, s);
    }
    return s;
  }

View Full Code Here

  /* (non-Javadoc)
   * @see org.graphstream.stream.netstream.NetStreamDecoder#getDefaultStream()
   */


  public synchronized ThreadProxyPipe getDefaultStream() {
    ThreadProxyPipe s = streams.get("default");
    if (s == null) {
      s = new ThreadProxyPipe();
      streams.put("default", s);
    }
    return s;


  }

View Full Code Here

   *            Start the layout thread immediately ? Else the start() method
   *            must be called later.
   */
  public LayoutRunner(Source source, Layout layout, boolean start) {
    this.layout = layout;
    this.pumpPipe = new ThreadProxyPipe();
    this.pumpPipe.addSink(layout);


    if (start)
      start();

View Full Code Here

   *            create the data, this is mostly always needed.
   */
  public LayoutRunner(Graph graph, Layout layout, boolean start,
      boolean replay) {
    this.layout = layout;
    this.pumpPipe = new ThreadProxyPipe();
    this.pumpPipe.addSink(layout);


    if (start)
      start();

View Full Code Here

   * Pipe out whose input is connected to the layout algorithm. You can safely
   * connect as a sink to it to receive events of the layout from a distinct
   * thread.
   */
  public ProxyPipe newLayoutPipe() {
    ThreadProxyPipe tpp = new ThreadProxyPipe();
    tpp.init(layout);
    
    return tpp;
  }

View Full Code Here

        // System.err.printf( "STOP!%n" );
      }
    }


    public ThreadProxyPipe getProxy() {
      ThreadProxyPipe toMain = new ThreadProxyPipe();
      toMain.init(graphic);


      // fromMain.synchronizeWith( toMain, graphic );


      return toMain;
    }

View Full Code Here

  }


  public DemoLayoutAndViewer() {
    boolean loop = true;
    Graph graph = new MultiGraph("test");
    Viewer viewer = new Viewer(new ThreadProxyPipe(graph));
    ProxyPipe fromViewer = viewer.newThreadProxyOnGraphicGraph();
    LinLog layout = new LinLog(false);
    
    layout.configure(a, r, true, force);

View Full Code Here

    new DemoViewerJComponents();
  }


  public DemoViewerJComponents() {
    Graph graph = new MultiGraph("main graph");
    ThreadProxyPipe toSwing = new ThreadProxyPipe(graph);
    Viewer viewer = new Viewer(toSwing);
    ProxyPipe fromSwing = viewer.newThreadProxyOnGraphicGraph();
    SpriteManager sman = new SpriteManager(graph);


    fromSwing.addAttributeSink(graph);

View Full Code Here

0 1 2 3

TOP

Related Classes of org.graphstream.stream.thread.ThreadProxyPipe

org.graphstream.stream.file.FileSinkImages

org.graphstream.stream.gephi.JSONReceiver

org.graphstream.stream.gephi.test.ExampleJSONReceiver

org.graphstream.stream.gephi.test.ExampleJSONStream

org.graphstream.stream.gephi.test.TestJSONStream

org.graphstream.stream.gephi.tutorial.LinLogLayoutReceiver

org.graphstream.stream.netstream.DefaultNetStreamDecoder

org.graphstream.stream.netstream.ExampleEventsReceiver

org.graphstream.stream.netstream.ExampleReceiver

org.graphstream.stream.netstream.ExampleTypesReceiver

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.