Linked to examples

Author: Froussios

Part 4 - Concurrency/1. Scheduling and threading.md

@@ -22,7 +22,7 @@ r.run(); // Execute on main thread
 new Thread(r).start();
 new Thread(r).start();
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SingleThreadedExample.java)
 ```
 onNext(1) on 1
 Received 1 on 1
@@ -66,7 +66,7 @@ Observable.create(o -> {
 
 System.out.println("Finished main: " + Thread.currentThread().getId());
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SubscribeOnExample.java)
 ```
 Main: 1
 Created on 1
@@ -77,7 +77,7 @@ Finished main: 1
 
 We see here that, not only is everything executed on the same thread, it is actually sequential: `subscribe` does not unblock until it has completed subscribing to (and thus creating) the observable, which includes executing the body of `create`'s lambda parameter. The calls to `onNext` within that lambda execute the entire chain of operators, all the way to the `println`. Effectively, subscribing on a `create`d observable is blocking.
 
-If you uncomment `.subscribeOn(Schedulers.newThread())`, the output now is
+If you uncomment `.subscribeOn(Schedulers.newThread())`, the [Output](/tests/java/itrx/chapter4/scheduling/SubscribeOnExample.java) now is
 ```
 Main: 1
 Finished main: 1
@@ -100,7 +100,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS)
 
 System.out.println("Finished main: " + Thread.currentThread().getId());
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SubscribeOnExample.java)
 ```
 Main: 1
 Finished main: 1
@@ -124,7 +124,7 @@ Observable.create(o -> {
 	.subscribe(i ->
 		System.out.println("Received " + i + " on " + Thread.currentThread().getId()));
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/ObserveOnExample.java)
 ```
 Created on 1
 Received 1 on 13
@@ -147,7 +147,7 @@ Observable.create(o -> {
 		System.out.println("After " + i + " on " + Thread.currentThread().getId()))
 	.subscribe();
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/ObserveOnExample.java)
 ```
 Created on 1
 Before 1 on 1
@@ -183,7 +183,7 @@ source
 	.unsubscribeOn(Schedulers.newThread())
 	.subscribe(System.out::println);
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/UnsubscribeOnExample.java)
 ```
 Subscribed on 1
 Producing on 1
@@ -256,7 +256,7 @@ worker.schedule(
 	() -> System.out.println(System.currentTimeMillis()-start),
 	5, TimeUnit.SECONDS);
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SchedulerExample.java)
 ```
 5033
 5035
@@ -282,7 +282,7 @@ worker.schedule(
 	() -> System.out.println(System.currentTimeMillis()-start),
 	5, TimeUnit.SECONDS);
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SchedulerExample.java)
 ```
 5032
 ```
@@ -304,7 +304,7 @@ worker.schedule(() -> {
 Thread.sleep(500);
 worker.unsubscribe();
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SchedulerExample.java)
 ```
 Action interrupted
 ```
@@ -326,7 +326,7 @@ worker.schedule(() -> {
 	System.out.println("End");
 });
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SchedulersExample.java)
 ```
 Start
 Inner
@@ -346,7 +346,7 @@ worker.schedule(() -> {
 	System.out.println("End");
 });
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SchedulersExample.java)
 ```
 Start
 End
@@ -378,7 +378,7 @@ worker.schedule(() -> {
 Thread.sleep(500);
 worker.schedule(() -> printThread("Again"));
 ```
-Output
+[Output](/tests/java/itrx/chapter4/scheduling/SchedulersExample.java)
 ```
 Main on 1
 Start on 11