Noriyuki TAKEI noriyukitakei

## HttpCommunicationListener.java
package statelessservice;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.InetSocketAddress;

## settings.gradle
// 以下の3つのプロジェクトをサブプロジェクトとして指定します。
include 'ChatWeb'

include 'ChatData'

include ':ChatRPC'

## build.gradle
apply plugin: 'java'
apply plugin: 'eclipse'

// 全てのサブプロジェクトにJavaプラグインを使う設定です。
subprojects {
    apply plugin: 'java'
}

// タスクを指定しなかった場合、以下の順番でタスクが実行されるという
// 設定を全てのサブプロジェクトに対して行う設定です。

## ServiceManifest.xml
<?xml version="1.0" encoding="utf-8" ?>
<ServiceManifest Name="ChatWebPkg" Version="1.0.0" xmlns="http://schemas.microsoft.com/2011/01/fabric" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <Description>Service that implements a ChatWeb service</Description>
  <ServiceTypes>
    <StatelessServiceType ServiceTypeName="ChatWebType" />
  </ServiceTypes>
  <CodePackage Name="Code" Version="1.0.0">
    <EntryPoint>
      <ExeHost>
        <Program>entryPoint.sh</Program>

## index.html
<html>
  <head>
    <title>ちゃっと</title>
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
    <style>
      .chat-box {
          width: 100%;
          height: auto;
          overflow: hidden;
          margin-bottom: 20px;

## ComletableFutureSample4.java
package thread.sample;

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class ComletableFutureSample4 {
	public static void main(String[] args) {

## ComletableFutureSample3.java
package thread.sample;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.function.Consumer;
import java.util.function.Supplier;

public class ComletableFutureSample3 {
	public static void main(String[] args) {

## ComletableFutureSample2.java
package thread.sample;

import java.util.concurrent.CompletableFuture;

public class ComletableFutureSample2 {
	public static void main(String[] args) {

		// 戻り値が固定で決まっているときは、CompletableFutureのstaticメソッドの
		// completedFutureを使います。
		CompletableFuture<?> cf = CompletableFuture.completedFuture("hoge");

## ComletableFutureSample1.java
package thread.sample;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ComletableFutureSample1 {
	public static void main(String[] args) {

		ExecutorService executor = Executors.newSingleThreadExecutor();

## ExecutorSample2.java
package thread.sample;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class ExecutorSample2 {
	public static void main(String[] args) throws InterruptedException, ExecutionException {
	package statelessservice;

	import java.io.BufferedReader;
	import java.io.File;
	import java.io.FileInputStream;
	import java.io.IOException;
	import java.io.InputStream;
	import java.io.InputStreamReader;
	import java.io.OutputStream;
	import java.net.InetSocketAddress;
	// 以下の3つのプロジェクトをサブプロジェクトとして指定します。
	include 'ChatWeb'

	include 'ChatData'

	include ':ChatRPC'
	apply plugin: 'java'
	apply plugin: 'eclipse'

	// 全てのサブプロジェクトにJavaプラグインを使う設定です。
	subprojects {
	apply plugin: 'java'
	}

	// タスクを指定しなかった場合、以下の順番でタスクが実行されるという
	// 設定を全てのサブプロジェクトに対して行う設定です。
	<?xml version="1.0" encoding="utf-8" ?>
	<ServiceManifest Name="ChatWebPkg" Version="1.0.0" xmlns="http://schemas.microsoft.com/2011/01/fabric" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
	<Description>Service that implements a ChatWeb service</Description>
	<ServiceTypes>
	<StatelessServiceType ServiceTypeName="ChatWebType" />
	</ServiceTypes>
	<CodePackage Name="Code" Version="1.0.0">
	<EntryPoint>
	<ExeHost>
	<Program>entryPoint.sh</Program>
	<html>
	<head>
	<title>ちゃっと</title>
	<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
	<style>
	.chat-box {
	width: 100%;
	height: auto;
	overflow: hidden;
	margin-bottom: 20px;
	package thread.sample;

	import java.util.Arrays;
	import java.util.List;
	import java.util.concurrent.CompletableFuture;
	import java.util.concurrent.ExecutionException;

	public class ComletableFutureSample4 {
	public static void main(String[] args) {
	package thread.sample;

	import java.util.concurrent.CompletableFuture;
	import java.util.concurrent.ExecutorService;
	import java.util.concurrent.Executors;
	import java.util.function.Consumer;
	import java.util.function.Supplier;

	public class ComletableFutureSample3 {
	public static void main(String[] args) {
	package thread.sample;

	import java.util.concurrent.CompletableFuture;

	public class ComletableFutureSample2 {
	public static void main(String[] args) {

	// 戻り値が固定で決まっているときは、CompletableFutureのstaticメソッドの
	// completedFutureを使います。
	CompletableFuture<?> cf = CompletableFuture.completedFuture("hoge");
	package thread.sample;

	import java.util.concurrent.Callable;
	import java.util.concurrent.ExecutionException;
	import java.util.concurrent.ExecutorService;
	import java.util.concurrent.Executors;
	import java.util.concurrent.Future;

	public class ExecutorSample2 {
	public static void main(String[] args) throws InterruptedException, ExecutionException {