Package ai.rapids.cudf

Class Cuda.Stream

java.lang.Object

ai.rapids.cudf.Cuda.Stream

All Implemented Interfaces:

AutoCloseable

Enclosing class:

Cuda

public static final class Cuda.Stream
extends Object
implements AutoCloseable

A class representing a CUDA stream

Constructor Summary

Constructors

Constructor	Description
Stream(boolean isNonBlocking)	Create a new CUDA stream

Method Summary

Modifier and Type	Method	Description
void	close()
long	getStream()
void	sync()	Block the thread to wait until all pending work on this stream completes.
String	toString()
void	waitOn(Cuda.Event event)	Have this stream not execute new work until the work recorded in event completes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

Stream

public Stream(boolean isNonBlocking)

Create a new CUDA stream

Parameters:

isNonBlocking - whether stream should be non-blocking with respect to the default stream

Method Details

waitOn

public void waitOn(Cuda.Event event)

Have this stream not execute new work until the work recorded in event completes.

Parameters:

event - the event to wait on.

getStream

public long getStream()

sync

public void sync()

Block the thread to wait until all pending work on this stream completes. Note that this does not follow any of the java threading standards. Interrupt will not work to wake up the thread.

toString

public String toString()

Overrides:

toString in class Object

close

public void close()

Specified by:

close in interface AutoCloseable