Package com.upmem.dpu

Class DpuSetAsync


  • public final class DpuSetAsync
    extends java.lang.Object
    Asynchronous version of the methods provided by a DPU set.
    See Also:
    DpuSet
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void call​(DpuCallback callback)
      Asynchronously call the provided callback on the DPU set.
      void call​(DpuCallback callback, boolean blocking, boolean singleCall)
      Asynchronously call the provided callback on the DPU set.
      void copy​(byte[][] dstBuffers, DpuSymbol srcSymbol)  
      void copy​(byte[][] dstBuffers, java.lang.String srcSymbol)  
      void copy​(DpuSymbol dstSymbol, byte[] srcBuffer)  
      void copy​(DpuSymbol dstSymbol, byte[][] srcBuffers)  
      void copy​(java.lang.String dstSymbol, byte[] srcBuffer)  
      void copy​(java.lang.String dstSymbol, byte[][] srcBuffers)  
      void exec()  
      void exec​(java.io.PrintStream logStream)  
      void sync()
      Wait for the end of all enqueued asynchronous operations.
      • Methods inherited from class java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • copy

        public void copy​(java.lang.String dstSymbol,
                         byte[][] srcBuffers)
                  throws DpuException
        Throws:
        DpuException
      • copy

        public void copy​(byte[][] dstBuffers,
                         java.lang.String srcSymbol)
                  throws DpuException
        Throws:
        DpuException
      • call

        public void call​(DpuCallback callback,
                         boolean blocking,
                         boolean singleCall)
                  throws DpuException
        Asynchronously call the provided callback on the DPU set.
        Parameters:
        callback - The function to be called on the DPU set.
        blocking - Whether other asynchronous operations must wait the end of the callback before starting.
        singleCall - Whether the callback is done once for the whole DPU set or once per DPU rank.
        Throws:
        DpuException - When the callback cannot be registered.
        See Also:
        DpuCallback
      • call

        public void call​(DpuCallback callback)
                  throws DpuException
        Asynchronously call the provided callback on the DPU set.

        The callback is called once per DPU rank and blocks the other asynchronous operations.

        Parameters:
        callback - The function to be called on each DpuRank of the DPU set.
        Throws:
        DpuException - When the callback cannot be registered.
        See Also:
        DpuCallback
      • sync

        public void sync()
                  throws DpuException
        Wait for the end of all enqueued asynchronous operations.
        Throws:
        DpuException - When any of the asynchronous methods throws an Exception.
        See Also:
        DpuException