wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-20 12:40:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Refine Java "Ray Core Walkthrough" doc (#9836)

Browse Source
This commit is contained in:
Hao Chen
2020-07-31 15:35:43 +08:00
committed by GitHub
parent 3900643948
commit 6fb6bd3e61
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
doc/source/walkthrough.rst
+10 -6
View File
@@ -10,7 +10,7 @@ This walkthrough will overview the core concepts of Ray:
With Ray, your code will work on a single machine and can be easily scaled to large cluster.
Java demo code in this documentation can be found `here <https://github.com/ray-project/ray/blob/master/java/test/src/main/java/io/ray/docdemo/WalkthroghDemo.java>`__.
Java demo code in this documentation can be found `here <https://github.com/ray-project/ray/blob/master/java/test/src/main/java/io/ray/docdemo/WalkthroughDemo.java>`__.
Installation
------------
@@ -113,9 +113,11 @@ Ray enables arbitrary functions to be executed asynchronously. These asynchronou
// The result can be retrieved with ``ObjectRef::get``.
Assert.assertTrue(res.get() == 1);
public static int slowFunction() throws InterruptedException {
TimeUnit.SECONDS.sleep(10);
return 1;
public class MyRayApp {
public static int slowFunction() throws InterruptedException {
TimeUnit.SECONDS.sleep(10);
return 1;
}
}
// Invocations of Ray remote functions happen in parallel.
@@ -149,8 +151,10 @@ Passing object refs to remote functions
.. code-tab:: java
public static int functionWithAnArgument(int value) {
return value + 1;
public class MyRayApp {
public static int functionWithAnArgument(int value) {
return value + 1;
}
}
ObjectRef<Integer> objRef1 = Ray.task(MyRayApp::myFunction).remote();