Skip to content

J
java9Features
Commit 4c38c794 authored by vikram singh's avatar vikram singh
Browse files
Options

Revert "added specified imports, reallocated the variables to class level and... 

Revert "added specified imports, reallocated the variables to class level and instance variable as per the requirement,Used logger for logging in almost every classes"

This reverts commit ecf36f46.
parent ecf36f46
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 848 additions and 515 deletions
.idea/.name deleted 100644 → 0
View file @ ecf36f46
java9Features
\ No newline at end of file
.idea/checkstyle-idea.xml deleted 100644 → 0
View file @ ecf36f46
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CheckStyle-IDEA">
<option name="configuration">
<map>
<entry key="checkstyle-version" value="8.29" />
<entry key="copy-libs" value="false" />
<entry key="location-0" value="BUNDLED:(bundled):Sun Checks" />
<entry key="location-1" value="BUNDLED:(bundled):Google Checks" />
<entry key="scan-before-checkin" value="false" />
<entry key="scanscope" value="JavaOnly" />
<entry key="suppress-errors" value="false" />
</map>
</option>
</component>
</project>
\ No newline at end of file
.idea/gradle.xml
View file @ 4c38c794
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project version="4"> <project version="4">
<component name="GradleMigrationSettings" migrationVersion="1" />
<component name="GradleSettings"> <component name="GradleSettings">
<option name="linkedExternalProjectsSettings"> <option name="linkedExternalProjectsSettings">
<GradleProjectSettings> <GradleProjectSettings>
<option name="delegatedBuild" value="true" />
<option name="testRunner" value="GRADLE" />
<option name="distributionType" value="DEFAULT_WRAPPED" /> <option name="distributionType" value="DEFAULT_WRAPPED" />
<option name="externalProjectPath" value="$PROJECT_DIR$" /> <option name="externalProjectPath" value="$PROJECT_DIR$" />
<option name="modules"> <option name="modules">
......
.idea/jarRepositories.xml deleted 100644 → 0
View file @ ecf36f46
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
<remote-repository>
<option name="id" value="MavenRepo" />
<option name="name" value="MavenRepo" />
<option name="url" value="https://repo.maven.apache.org/maven2/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
.idea/misc.xml
View file @ 4c38c794
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project version="4"> <project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" /> <component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="ProjectRootManager" version="2" languageLevel="JDK_1_9" default="false" project-jdk-name="9" project-jdk-type="JavaSDK"> <component name="ProjectRootManager" version="2" languageLevel="JDK_1_9" default="false" project-jdk-name="11" project-jdk-type="JavaSDK">
<output url="file://$PROJECT_DIR$/out" /> <output url="file://$PROJECT_DIR$/out" />
</component> </component>
</project> </project>
\ No newline at end of file
.idea/vcs.xml
View file @ 4c38c794
...@@ -2,6 +2,5 @@ ...@@ -2,6 +2,5 @@
<project version="4"> <project version="4">
<component name="VcsDirectoryMappings"> <component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$/../" vcs="Git" /> <mapping directory="$PROJECT_DIR$/../" vcs="Git" />
<mapping directory="$PROJECT_DIR$" vcs="Git" />
</component> </component>
</project> </project>
\ No newline at end of file
.idea/workspace.xml
View file @ 4c38c794
This diff is collapsed.
build.gradle
View file @ 4c38c794
...@@ -12,7 +12,5 @@ repositories { ...@@ -12,7 +12,5 @@ repositories {
} }
dependencies { dependencies {
compileOnly 'org.projectlombok:lombok:1.18.12'
testCompile group: 'junit', name: 'junit', version: '4.12' testCompile group: 'junit', name: 'junit', version: '4.12'
} }
gradle/wrapper/gradle-wrapper.properties
View file @ 4c38c794
#Fri Apr 03 12:57:31 IST 2020
distributionBase=GRADLE_USER_HOME distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists distributionPath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-4.10.3-bin.zip
zipStoreBase=GRADLE_USER_HOME zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists zipStorePath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-4.10.3-all.zip
src/main/java/com/nisum/java9Features/DiamondOperator/MyGenClass.java
View file @ 4c38c794
package com.nisum.java9Features.DiamondOperator; package com.nisum.java9Features.DiamondOperator;
import java.util.logging.Logger;
public class MyGenClass<T> { public class MyGenClass<T> {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
T obj; T obj;
public MyGenClass(T obj) public MyGenClass(T obj)
{ {
...@@ -16,6 +12,6 @@ public class MyGenClass<T> { ...@@ -16,6 +12,6 @@ public class MyGenClass<T> {
} }
public void process() public void process()
{ {
log.info("Processing obj..."); System.out.println("Processing obj...");
} }
} }
src/main/java/com/nisum/java9Features/DiamondOperator/Test.java
View file @ 4c38c794
package com.nisum.java9Features.DiamondOperator; package com.nisum.java9Features.DiamondOperator;
import java.util.logging.Logger;
public class Test { public class Test {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void main(String[] args) { public static void main(String[] args) {
MyGenClass<String> c1 = new MyGenClass<String>("Durga") { MyGenClass<String> c1 = new MyGenClass<String>("Durga") {
public void process() { public void process() {
log.info("Processing... " + getObj()); System.out.println("Processing... " + getObj());
} }
}; };
c1.process(); c1.process();
MyGenClass<String> c2 = new MyGenClass<>("Pavan") { MyGenClass<String> c2 = new MyGenClass<>("Pavan") {
public void process() { public void process() {
log.info("Processing... " + getObj()); System.out.println("Processing... " + getObj());
} }
}; };
c2.process(); c2.process();
......
src/main/java/com/nisum/java9Features/FactoryMethodsForUnmodifiableCollections/UnmodifiableList.java
View file @ 4c38c794
package com.nisum.java9Features.FactoryMethodsForUnmodifiableCollections; package com.nisum.java9Features.FactoryMethodsForUnmodifiableCollections;
import java.util.*;
import java.util.List;
import java.util.logging.Logger;
public class UnmodifiableList { public class UnmodifiableList {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
static Employee e1,e2,e3,e5;
public static void main(String[] args) { public static void main(String[] args) {
e1=new Employee(100,"sunny"); Employee e1=new Employee(100,"sunny");
e2=new Employee(101, "Bunny"); Employee e2=new Employee(101, "Bunny");
e3=new Employee(102,"Chinny"); Employee e3=new Employee(102,"Chinny");
// Employee e4=null; // Employee e4=null;
//List<Employee> emplist=List.of(e1,e2,e3,e4); //List<Employee> emplist=List.of(e1,e2,e3,e4);
List<Employee> emplist=List.of(e1,e2,e3); List<Employee> emplist=List.of(e1,e2,e3);
log.info("{}"+ emplist); System.out.println(emplist);
e5=new Employee(103,"Laddu"); Employee e5=new Employee(103,"Laddu");
//emplist.add(e5); // Unsupported Exception //emplist.add(e5); // Unsupported Exception
} }
......
src/main/java/com/nisum/java9Features/FactoryMethodsForUnmodifiableCollections/UnmodifiableMap.java
View file @ 4c38c794
package com.nisum.java9Features.FactoryMethodsForUnmodifiableCollections; package com.nisum.java9Features.FactoryMethodsForUnmodifiableCollections;
import java.sql.*;
import java.util.*;
import java.util.Map;
import java.util.logging.Logger;
import static java.util.Map.entry; import static java.util.Map.entry;
public class UnmodifiableMap { public class UnmodifiableMap {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
static Map<String,String> map=Map.of("A","Apple","B","Banana","C","Cat","D","Dog")
,m;
static Map.Entry<String,String> e1,e2,e3;
public static void main(String[] args) { public static void main(String[] args) {
log.info("{}"+map); Map<String,String> map=Map.of("A","Apple","B","Banana","C","Cat","D","Dog");
System.out.println(map);
/* Map<String,String> map1=Map.of("A","Apple","A","Banana","C","Cat","D","Dog"); /* Map<String,String> map1=Map.of("A","Apple","A","Banana","C","Cat","D","Dog");
System.out.println(map1); // IllegalArgumentException*/ System.out.println(map1); // IllegalArgumentException*/
/*Map<String,String> map2=Map.of("A",null,"B","Banana"); // NullPointerException /*Map<String,String> map2=Map.of("A",null,"B","Banana"); // NullPointerException
System.out.println(map2);*/ System.out.println(map2);*/
e1= entry("A","Apple"); Map.Entry<String,String> e1= entry("A","Apple");
e2= entry("B","Banana"); Map.Entry<String,String> e2= entry("B","Banana");
e3= entry("C","Cat"); Map.Entry<String,String> e3= entry("C","Cat");
m=Map.ofEntries(e1,e2,e3); Map<String,String> m=Map.ofEntries(e1,e2,e3);
log.info("{}"+m); System.out.println(m);
/* Map<String,String> map3=Map.ofEntries(entry(null,"Apple"),entry("B","Banana")); // NullPointerException /* Map<String,String> map3=Map.ofEntries(entry(null,"Apple"),entry("B","Banana")); // NullPointerException
System.out.println(map3);*/ System.out.println(map3);*/
......
src/main/java/com/nisum/java9Features/FactoryMethodsForUnmodifiableCollections/UnmodifiableSet.java
View file @ 4c38c794
package com.nisum.java9Features.FactoryMethodsForUnmodifiableCollections; package com.nisum.java9Features.FactoryMethodsForUnmodifiableCollections;
import java.util.*;
import java.util.Set;
import java.util.logging.Logger;
public class UnmodifiableSet { public class UnmodifiableSet {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
static Employee e1,e2,e3,e5;
static Set<Employee> emplist;
public static void main(String[] args) { public static void main(String[] args) {
e1=new Employee(100,"sunny"); Employee e1=new Employee(100,"sunny");
e2=new Employee(101, "Bunny"); Employee e2=new Employee(101, "Bunny");
e3=new Employee(102,"Chinny"); Employee e3=new Employee(102,"Chinny");
// Employee e4=null; // Employee e4=null;
//List<Employee> emplist=List.of(e1,e2,e3,e4); //List<Employee> emplist=List.of(e1,e2,e3,e4);
emplist=Set.of(e1,e2,e3,e3); Set<Employee> emplist=Set.of(e1,e2,e3,e3);
log.info("{} "+ emplist); System.out.println(emplist);
Employee e5=new Employee(103,"Laddu"); Employee e5=new Employee(103,"Laddu");
//emplist.add(e5); // Unsupported Exception //emplist.add(e5); // Unsupported Exception
......
src/main/java/com/nisum/java9Features/PrivateMethods/Java9Interf.java
View file @ 4c38c794
package com.nisum.java9Features.PrivateMethods; package com.nisum.java9Features.PrivateMethods;
import java.util.logging.Logger;
public interface Java9Interf public interface Java9Interf
{ {
final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
default void m1() default void m1()
{ {
m3(); m3();
...@@ -16,6 +12,6 @@ public interface Java9Interf ...@@ -16,6 +12,6 @@ public interface Java9Interf
} }
private void m3() private void m3()
{ {
log.info("common functionality of methods m1 & m2"); System.out.println("common functionality of methods m1 & m2");
} }
} }
src/main/java/com/nisum/java9Features/PrivateMethods/Java9InterfStatic.java
View file @ 4c38c794
package com.nisum.java9Features.PrivateMethods; package com.nisum.java9Features.PrivateMethods;
import java.util.logging.Logger;
public interface Java9InterfStatic { public interface Java9InterfStatic {
final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void m1() public static void m1()
{ {
m3(); m3();
...@@ -15,6 +11,6 @@ public interface Java9InterfStatic { ...@@ -15,6 +11,6 @@ public interface Java9InterfStatic {
} }
private static void m3() private static void m3()
{ {
log.info("common functionality of methods m1 & m2"); System.out.println("common functionality of methods m1 & m2");
} }
} }
src/main/java/com/nisum/java9Features/ProcessAPI/CurrentProcessInfo.java
View file @ 4c38c794
package com.nisum.java9Features.ProcessAPI; package com.nisum.java9Features.ProcessAPI;
import java.util.logging.Logger;
public class CurrentProcessInfo { public class CurrentProcessInfo {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME); public static void main(String[] args) throws Exception {
static ProcessHandle p; ProcessHandle p = ProcessHandle.current();
static ProcessHandle.Info info; ProcessHandle.Info info = p.info();
public static void main(String[] args) throws Exception { System.out.println("Complete Process Inforamtion:\n" + info);
p = ProcessHandle.current(); System.out.println("User: " + info.user().get());
info = p.info(); System.out.println("Command: " + info.command().get());
log.info("Complete Process Inforamtion:\n" + info); System.out.println("Start Time: " + info.startInstant().get());
log.info("User: " + info.user().get()); System.out.println("Total CPU Time Acquired: " + info.totalCpuDuration().get());
log.info("Command: " + info.command().get());
log.info("Start Time: " + info.startInstant().get());
log.info("Total CPU Time Acquired: " + info.totalCpuDuration().get());
} }
} }
src/main/java/com/nisum/java9Features/ProcessAPI/DestroyProcessFromProcessBuilder.java
View file @ 4c38c794
package com.nisum.java9Features.ProcessAPI; package com.nisum.java9Features.ProcessAPI;
import lombok.extern.slf4j.Slf4j;
import java.util.logging.Logger;
public class DestroyProcessFromProcessBuilder { public class DestroyProcessFromProcessBuilder {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
static ProcessBuilder pb;
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
pb= new ProcessBuilder("java", "sample"); ProcessBuilder pb = new ProcessBuilder("java", "sample");
Process p = pb.start(); Process p = pb.start();
log.info("Process Started with id:" + p.pid()); System.out.println("Process Started with id:" + p.pid());
Thread.sleep(10000); Thread.sleep(10000);
log.info("Destroying the process with id:" + p.pid()); System.out.println("Destroying the process with id:" + p.pid());
p.destroy(); p.destroy();
} }
......
src/main/java/com/nisum/java9Features/ProcessAPI/ProcessBasedOnID.java
View file @ 4c38c794
package com.nisum.java9Features.ProcessAPI; package com.nisum.java9Features.ProcessAPI;
import java.util.*;
import java.util.Optional;
import java.util.logging.Logger;
public class ProcessBasedOnID { public class ProcessBasedOnID {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
//need to get the pid from task manager //need to get the pid from task manager
Optional<ProcessHandle> opt = ProcessHandle.of(8408); Optional<ProcessHandle> opt = ProcessHandle.of(8408);
ProcessHandle p = opt.get(); ProcessHandle p = opt.get();
ProcessHandle.Info info = p.info(); ProcessHandle.Info info = p.info();
log.info("Complete Process Inforamtion:\n" + info); System.out.println("Complete Process Inforamtion:\n" + info);
log.info("User: " + info.user().get()); System.out.println("User: " + info.user().get());
log.info("Command: " + info.command().get()); System.out.println("Command: " + info.command().get());
log.info("Start Time: " + info.startInstant().get()); System.out.println("Start Time: " + info.startInstant().get());
log.info("Total CPU Time Acquired: " + info.totalCpuDuration().get()); System.out.println("Total CPU Time Acquired: " + info.totalCpuDuration().get());
} }
} }
src/main/java/com/nisum/java9Features/ProcessAPI/ProcessID.java
View file @ 4c38c794
package com.nisum.java9Features.ProcessAPI; package com.nisum.java9Features.ProcessAPI;
import java.util.logging.Logger;
public class ProcessID { public class ProcessID {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
ProcessHandle p = ProcessHandle.current(); ProcessHandle p = ProcessHandle.current();
long pid = p.pid(); long pid = p.pid();
log.info("The PID of current running JVM instance :" + pid); System.out.println("The PID of current running JVM instance :" + pid);
Thread.sleep(100000); Thread.sleep(100000);
} }
} }
src/main/java/com/nisum/java9Features/ReactiveStreams/EmpHelper.java
View file @ 4c38c794
package com.nisum.java9Features.ReactiveStreams; package com.nisum.java9Features.ReactiveStreams;
import java.util.*;
import java.util.ArrayList;
import java.util.List;
public class EmpHelper { public class EmpHelper {
public static List<Employee> getEmps() { public static List<Employee> getEmps() {
......
src/main/java/com/nisum/java9Features/ReactiveStreams/MyReactiveApp.java
View file @ 4c38c794
package com.nisum.java9Features.ReactiveStreams; package com.nisum.java9Features.ReactiveStreams;
import java.util.*;
import java.util.List; import java.util.concurrent.*;
import java.util.concurrent.SubmissionPublisher;
import java.util.logging.Logger;
public class MyReactiveApp { public class MyReactiveApp {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void main(String args[]) throws InterruptedException { public static void main(String args[]) throws InterruptedException {
// Create Publisher // Create Publisher
SubmissionPublisher<Employee> publisher = new SubmissionPublisher<>(); SubmissionPublisher<Employee> publisher = new SubmissionPublisher<>();
...@@ -19,7 +15,7 @@ public class MyReactiveApp { ...@@ -19,7 +15,7 @@ public class MyReactiveApp {
List<Employee> emps = EmpHelper.getEmps(); List<Employee> emps = EmpHelper.getEmps();
// Publish items // Publish items
log.info("Publishing Items to Subscriber"); System.out.println("Publishing Items to Subscriber");
emps.stream().forEach(i -> publisher.submit(i)); emps.stream().forEach(i -> publisher.submit(i));
// logic to wait till processing of all messages are over // logic to wait till processing of all messages are over
...@@ -29,7 +25,7 @@ public class MyReactiveApp { ...@@ -29,7 +25,7 @@ public class MyReactiveApp {
// close the Publisher // close the Publisher
publisher.close(); publisher.close();
log.info("Exiting the app"); System.out.println("Exiting the app");
} }
} }
src/main/java/com/nisum/java9Features/ReactiveStreams/MySubscriber.java
View file @ 4c38c794
package com.nisum.java9Features.ReactiveStreams; package com.nisum.java9Features.ReactiveStreams;
import java.util.concurrent.*;
import java.util.concurrent.Flow.Subscriber; import java.util.concurrent.Flow.Subscriber;
import java.util.concurrent.Flow.Subscription; import java.util.concurrent.Flow.Subscription;
import java.util.logging.Logger;
public class MySubscriber implements Subscriber<Employee> { public class MySubscriber implements Subscriber<Employee> {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
private Subscription subscription; private Subscription subscription;
private int counter = 0; private int counter = 0;
@Override @Override
public void onSubscribe(Subscription subscription) { public void onSubscribe(Subscription subscription) {
log.info("Subscribed"); System.out.println("Subscribed");
this.subscription = subscription; this.subscription = subscription;
this.subscription.request(1); //requesting data from publisher this.subscription.request(1); //requesting data from publisher
log.info("onSubscribe requested 1 item"); System.out.println("onSubscribe requested 1 item");
} }
@Override @Override
public void onNext(Employee item) { public void onNext(Employee item) {
log.info("Processing Employee " + item); System.out.println("Processing Employee " + item);
counter++; counter++;
this.subscription.request(1); this.subscription.request(1);
} }
@Override @Override
public void onError(Throwable e) { public void onError(Throwable e) {
log.info("Some error happened"); System.out.println("Some error happened");
e.printStackTrace(); e.printStackTrace();
} }
@Override @Override
public void onComplete() { public void onComplete() {
log.info("All Processing Done"); System.out.println("All Processing Done");
} }
public int getCounter() { public int getCounter() {
......
src/main/java/com/nisum/java9Features/StreamApi/TestDropWhile.java
View file @ 4c38c794
package com.nisum.java9Features.StreamApi; package com.nisum.java9Features.StreamApi;
import java.util.*;
import java.util.ArrayList; import java.util.stream.*;
import java.util.List;
import java.util.logging.Logger;
import java.util.stream.Collectors;
public class TestDropWhile { public class TestDropWhile {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void main(String[] args) { public static void main(String[] args) {
ArrayList<Integer> l1 = new ArrayList<Integer>(); ArrayList<Integer> l1 = new ArrayList<Integer>();
l1.add(2); l1.add(2);
...@@ -19,8 +13,9 @@ public class TestDropWhile { ...@@ -19,8 +13,9 @@ public class TestDropWhile {
l1.add(6); l1.add(6);
l1.add(5); l1.add(5);
l1.add(8); l1.add(8);
log.info("Initial List:" + l1); System.out.println("Initial List:" + l1);
List<Integer> l2 = l1.stream().dropWhile(i -> i % 2 == 0).collect(Collectors.toList()); List<Integer> l2 = l1.stream().dropWhile(i -> i % 2 == 0).collect(Collectors.toList());
log.info("After dropWhile:" + l2); System.out.println("After dropWhile:" + l2);
} }
} }
src/main/java/com/nisum/java9Features/StreamApi/TestIterate.java
View file @ 4c38c794
package com.nisum.java9Features.StreamApi; package com.nisum.java9Features.StreamApi;
import java.util.stream.*;
import java.util.logging.Logger;
import java.util.stream.Stream;
public class TestIterate { public class TestIterate {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void main(String[] args) { public static void main(String[] args) {
//Stream.iterate(1, x->x+1).forEach(System.out::println); // return infinite elements //Stream.iterate(1, x->x+1).forEach(System.out::println); // return infinite elements
Stream.iterate(1, x->x+1).limit(5).forEach(System.out::println); Stream.iterate(1, x->x+1).limit(5).forEach(System.out::println);
log.info("3argument iterate"); System.out.println("3argument iterate");
Stream.iterate(1,x->x<10, x->x+1).forEach(System.out::println); Stream.iterate(1,x->x<10, x->x+1).forEach(System.out::println);
} }
} }
src/main/java/com/nisum/java9Features/StreamApi/TestOfNullable.java
View file @ 4c38c794
package com.nisum.java9Features.StreamApi; package com.nisum.java9Features.StreamApi;
import java.util.*;
import java.util.ArrayList; import java.util.stream.*;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Logger;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class TestOfNullable { public class TestOfNullable {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void main(String[] args) { public static void main(String[] args) {
List<String> l = new ArrayList<String>(); List<String> l = new ArrayList<String>();
l.add("A"); l.add("A");
...@@ -20,12 +12,12 @@ public class TestOfNullable { ...@@ -20,12 +12,12 @@ public class TestOfNullable {
l.add("C"); l.add("C");
l.add("D"); l.add("D");
l.add(null); l.add(null);
log.info("l {}"+l); System.out.println(l);
List<String> l2 = l.stream().filter(o -> o != null).collect(Collectors.toList()); List<String> l2 = l.stream().filter(o -> o != null).collect(Collectors.toList());
log.info("l2 {}"+l2); System.out.println(l2);
List<String> l3 = l.stream().flatMap(o -> Stream.ofNullable(o)).collect(Collectors.toList()); List<String> l3 = l.stream().flatMap(o -> Stream.ofNullable(o)).collect(Collectors.toList());
log.info("l3 {}"+l3); System.out.println(l3);
Map<String, String> m = new HashMap<>(); Map<String, String> m = new HashMap<>();
m.put("A", "Apple"); m.put("A", "Apple");
...@@ -34,9 +26,9 @@ public class TestOfNullable { ...@@ -34,9 +26,9 @@ public class TestOfNullable {
m.put("D", "Dog"); m.put("D", "Dog");
m.put("E", null); m.put("E", null);
List<String> l4 = m.entrySet().stream().map(e -> e.getKey()).collect(Collectors.toList()); List<String> l4 = m.entrySet().stream().map(e -> e.getKey()).collect(Collectors.toList());
log.info("l4 {}"+l4); System.out.println(l4);
List<String> l5 = m.entrySet().stream().flatMap(e -> Stream.ofNullable(e.getValue())).collect(Collectors.toList()); List<String> l5 = m.entrySet().stream().flatMap(e -> Stream.ofNullable(e.getValue())).collect(Collectors.toList());
log.info("l5 {}"+l5); System.out.println(l5);
} }
} }
src/main/java/com/nisum/java9Features/StreamApi/TestTakeWhile.java
View file @ 4c38c794
package com.nisum.java9Features.StreamApi; package com.nisum.java9Features.StreamApi;
import java.util.ArrayList; import java.util.*;
import java.util.stream.*;
import java.util.List;
import java.util.logging.Logger;
import java.util.stream.Collectors;
public class TestTakeWhile { public class TestTakeWhile {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void main(String[] args) { public static void main(String[] args) {
ArrayList<Integer> l1 = new ArrayList<Integer>(); ArrayList<Integer> l1 = new ArrayList<Integer>();
l1.add(2); l1.add(2);
l1.add(4); l1.add(4);
...@@ -21,10 +13,10 @@ public class TestTakeWhile { ...@@ -21,10 +13,10 @@ public class TestTakeWhile {
l1.add(6); l1.add(6);
l1.add(5); l1.add(5);
l1.add(8); l1.add(8);
log.info("Initial List:" + l1); System.out.println("Initial List:" + l1);
List<Integer> l2 = l1.stream().filter(i -> i % 2 == 0).collect(Collectors.toList()); List<Integer> l2 = l1.stream().filter(i -> i % 2 == 0).collect(Collectors.toList());
log.info("After Filtering:" + l2); System.out.println("After Filtering:" + l2);
List<Integer> l3 = l1.stream().takeWhile(i -> i % 2 == 0).collect(Collectors.toList()); List<Integer> l3 = l1.stream().takeWhile(i -> i % 2 == 0).collect(Collectors.toList());
log.info("After takeWhile:" + l3); System.out.println("After takeWhile:" + l3);
} }
} }
src/main/java/com/nisum/java9Features/TryWithResourcesEnhancements/MyResources.java
View file @ 4c38c794
package com.nisum.java9Features.TryWithResourcesEnhancements; package com.nisum.java9Features.TryWithResourcesEnhancements;
import java.util.logging.Logger;
public class MyResources implements AutoCloseable { public class MyResources implements AutoCloseable {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
MyResources() MyResources()
{ {
log.info("Resource Creation..."); System.out.println("Resource Creation...");
} }
public void doProcess() public void doProcess()
{ {
log.info("Resource Processing..."); System.out.println("Resource Processing...");
} }
public void close() public void close()
{ {
log.info("Resource Closing..."); System.out.println("Resource Closing...");
} }
} }
src/main/java/com/nisum/java9Features/TryWithResourcesEnhancements/TryWithResourceApp.java
View file @ 4c38c794
package com.nisum.java9Features.TryWithResourcesEnhancements; package com.nisum.java9Features.TryWithResourcesEnhancements;
import lombok.extern.flogger.Flogger;
import lombok.extern.slf4j.Slf4j;
import java.util.logging.Logger;
//@Slf4j
public class TryWithResourceApp { public class TryWithResourceApp {
private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);
public static void preJDK7() public static void preJDK7()
{ {
MyResources r=null; MyResources r=null;
...@@ -18,7 +11,7 @@ public class TryWithResourceApp { ...@@ -18,7 +11,7 @@ public class TryWithResourceApp {
} }
catch (Exception e) catch (Exception e)
{ {
log.info("Handling:"+e); System.out.println("Handling:"+e);
} }
finally finally
{ {
...@@ -31,7 +24,7 @@ public class TryWithResourceApp { ...@@ -31,7 +24,7 @@ public class TryWithResourceApp {
} }
catch (Exception e) catch (Exception e)
{ {
log.info("Handling:"+e); System.out.println("Handling:"+e);
} }
} }
} }
...@@ -43,7 +36,7 @@ public class TryWithResourceApp { ...@@ -43,7 +36,7 @@ public class TryWithResourceApp {
} }
catch(Exception e) catch(Exception e)
{ {
log.info("Handling:"+e); System.out.println("Handling:"+e);
} }
} }
public static void JDK9() public static void JDK9()
...@@ -55,7 +48,7 @@ public class TryWithResourceApp { ...@@ -55,7 +48,7 @@ public class TryWithResourceApp {
} }
catch(Exception e) catch(Exception e)
{ {
log.info("Handling:"+e); System.out.println("Handling:"+e);
} }
} }
public static void multipleJDK9() public static void multipleJDK9()
...@@ -73,23 +66,21 @@ public class TryWithResourceApp { ...@@ -73,23 +66,21 @@ public class TryWithResourceApp {
} }
catch(Exception e) catch(Exception e)
{ {
log.info("Handling:"+e); System.out.println("Handling:"+e);
} }
} }
public static void main(String[] args) public static void main(String[] args)
{ {
System.out.println("Program Execution With PreJDK7");
preJDK7();
log.info("Program Execution With PreJDK7"); System.out.println("Program Execution With JDK7");
JDK7();
preJDK7();
log.info("Program Execution With JDK7");
JDK7();
log.info("Program Execution With JDK9"); System.out.println("Program Execution With JDK9");
JDK9(); JDK9();
log.info("Program Execution Multiple Resources With JDK9"); System.out.println("Program Execution Multiple Resources With JDK9");
multipleJDK9(); multipleJDK9();
} }
} }
src/main/java/com/nisum/java9Features/http2/TestAsync.java
View file @ 4c38c794
//package com.nisum.java9Features.http2; package com.nisum.java9Features.http2;
//
//import jdk.incubator.http.HttpClient; import com.nisum.java9Features.DiamondOperator.*;
//import jdk.incubator.http.HttpHeaders;
//import jdk.incubator.http.HttpRequest; import java.net.*;
//import jdk.incubator.http.HttpResponse; import java.net.http.*;
// import java.util.*;
//import java.net.URI; import java.util.concurrent.*;
//import java.util.List;
//import java.util.Map; public class TestAsync {
//import java.util.concurrent.CompletableFuture; public static void main(String[] args) throws Exception {
//import java.util.logging.Logger; String url = "https://www.redbus.in/info/aboutus";
// sendGetAsyncRequest(url);
// }
//public class TestAsync {
// private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME); public static void sendGetAsyncRequest(String url) throws Exception {
// HttpClient client = HttpClient.newHttpClient();
// public static void main(String[] args) throws Exception { HttpRequest req = HttpRequest.newBuilder(new URI(url)).GET().build();
// String url = "https://www.redbus.in/info/aboutus"; System.out.println("Sending Asynchronous Request...");
// sendGetAsyncRequest(url); CompletableFuture<HttpResponse<String>> cf = client.sendAsync(req, HttpResponse.BodyHandlers.ofString());
// } int count = 0;
// while (!cf.isDone()) {
// public static void sendGetAsyncRequest(String url) throws Exception { System.out.println("Processing not done and doing other activity:" + ++count);
// HttpClient client = HttpClient.newHttpClient(); }
// HttpRequest req = HttpRequest.newBuilder(new URI(url)).GET().build(); processResponse(cf.get());
// log.info("Sending Asynchronous Request..."); }
// CompletableFuture<HttpResponse<String>> cf = client.sendAsync(req, HttpResponse.BodyHandler.asString());
// int count = 0; public static void processResponse(HttpResponse resp) {
// while (!cf.isDone()) { System.out.println("Status Code:" + resp.statusCode());
// log.info("Processing not done and doing other activity:" + ++count); //System.out.println("Response Body:"+resp.body());
// } HttpHeaders header = resp.headers();
// processResponse(cf.get()); Map<String, List<String>> map = header.map();
// } System.out.println("Response Headers");
// map.forEach((k, v) -> System.out.println("\t" + k + ":" + v));
// public static void processResponse(HttpResponse resp) { }
// log.info("Status Code:" + resp.statusCode());
// //System.out.println("Response Body:"+resp.body()); }
// HttpHeaders header = resp.headers();
// Map<String, List<String>> map = header.map();
// log.info("Response Headers");
// map.forEach((k, v) -> System.out.println("\t" + k + ":" + v));
// }
//
//}
src/main/java/com/nisum/java9Features/http2/TestSync.java
View file @ 4c38c794
//package com.nisum.java9Features.http2; package com.nisum.java9Features.http2;
//
//
//import jdk.incubator.http.HttpClient; import java.net.*;
//import jdk.incubator.http.HttpHeaders; import java.net.http.*;
//import jdk.incubator.http.HttpRequest; import java.nio.file.*;
//import jdk.incubator.http.HttpResponse; import java.util.*;
//
//import java.net.URI; public class TestSync {
//import java.util.List; public static void main(String[] args) throws Exception {
//import java.util.Map; String url = "https://www.redbus.in/info/aboutus";
//import java.util.concurrent.CompletableFuture; sendGetSyncRequest(url);
//import java.util.logging.Logger; }
//
//public class TestSync { public static void sendGetSyncRequest(String url) throws Exception {
// private final static Logger log =Logger.getLogger(Logger.GLOBAL_LOGGER_NAME); HttpClient client = HttpClient.newHttpClient();
// public static void main(String[] args) throws Exception { HttpRequest req = HttpRequest.newBuilder(new URI(url)).GET().build();
// String url = "https://www.redbus.in/info/aboutus"; HttpResponse resp = client.send(req, HttpResponse.BodyHandlers.ofString());
// sendGetSyncRequest(url); // HttpResponse resp1=client.send(req,HttpResponse.BodyHandlers.ofFile(Paths.get("abc.html")) );
// } processResponse(resp);
// }
// public static void sendGetSyncRequest(String url) throws Exception {
// HttpClient client = HttpClient.newHttpClient(); public static void processResponse(HttpResponse resp) {
// HttpRequest req = HttpRequest.newBuilder(new URI(url)).GET().build(); System.out.println("Status Code:" + resp.statusCode());
// HttpResponse resp = client.send(req, HttpResponse.BodyHandler.asString()); //System.out.println("Response Body:" + resp.body());
// // HttpResponse resp1=client.send(req,HttpResponse.BodyHandlers.ofFile(Paths.get("abc.html")) ); HttpHeaders header = resp.headers();
// processResponse(resp); Map<String, List<String>> map = header.map();
// } System.out.println("Response Headers");
// map.forEach((k, v) -> System.out.println("\t" + k + ":" + v));
// public static void processResponse(HttpResponse resp) { }
// log.info("Status Code: {}" + resp.statusCode());
// //System.out.println("Response Body:" + resp.body()); }
// HttpHeaders header = resp.headers(); \ No newline at end of file
// Map<String, List<String>> map = header.map();
// log.info("Response Headers");
// map.forEach((k, v) -> log.info("\t" + k + ":" + v));
// }
//
//}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment