Finish week 7

Author: ChuntaoLu

java_and_dataflow/counter.oz

@@ -0,0 +1,28 @@
+declare
+fun {Counter S}
+   fun {Count Lst M}
+      case Lst of
+         nil then [M#1]
+      [] X#Y|T then
+         if X==M then X#(Y+1)|T
+         else X#Y|{Count T M} end
+      end
+   end
+   local Cell={NewCell nil} in
+      fun {Consume Stream}
+         case Stream of H|T then
+            Cell:={Count @Cell H}
+            @Cell|{Consume T}
+         else _ end
+      end
+   end
+in
+   thread {Consume S} end
+end
+
+local InS X in
+   X={Counter InS}
+   InS=a|b|a|c|_
+   {Delay 2000}
+   {Browse X}
+end

java_and_dataflow/produce_consume_filter.oz

@@ -0,0 +1,37 @@
+declare
+fun {Producer N}
+   fun {Prod M}
+      if M<N+1 then M|{Prod M+1}
+      else nil end
+   end
+in
+   {Prod 1}
+end
+
+fun {Filter S}
+   case S of H|T then
+      if (H mod 2)==1 then H|{Filter T}
+      else {Filter T} end
+   else nil end
+end
+
+fun {Consumer S}
+   case S of H|T then
+      H+{Consumer T}
+   else 0 end
+end
+
+proc {Disp S}
+   case S of H|T then
+      {Browse H}
+      {Disp T}
+   end
+end
+  
+
+local P F in
+   thread P={Producer 20} end
+   thread F={Filter P} end
+   %thread {Disp F} end
+   thread {Browse {Consumer F}} end
+end

java_and_dataflow/queue.oz

@@ -0,0 +1,56 @@
+declare
+class Queue
+   attr cell
+
+   meth init
+      cell:=nil
+   end
+
+   meth size($)
+      {Length @cell}
+   end
+
+   meth isEmpty($)
+      @cell==nil
+   end
+
+   meth front($)
+      if @cell==nil then
+         raise frontEmptyQueue end
+      else {Nth @cell {Length @cell}} end
+   end
+
+   meth enqueue(X)
+      cell:=X|@cell
+   end
+
+   meth dequeue($)
+      if @cell==nil then
+         raise dequeueEmptyQueue end
+      else local Len={Length @cell} H List in
+              H = {Nth @cell Len}
+              List=@cell
+              cell:=nil
+              for I in Len-1..1;~1 do
+                 cell:={Nth List I}|@cell
+              end
+              H
+           end
+      end
+   end
+end
+
+local S={New Queue init}  in
+   {Browse {S size($)}}
+   {Browse {S isEmpty($)}}
+   %{Browse {S top($)}}
+   {S enqueue(8)}
+   {S enqueue(7)}
+   {Browse {S size($)}}
+   {Browse {S isEmpty($)}}
+   {Browse {S front($)}}
+   {Browse {S dequeue($)}}
+   {Browse {S size($)}}
+   {Browse {S front($)}}
+   %{Browse {S pop($)}}
+end

java_and_dataflow/reverse.oz

@@ -0,0 +1,14 @@
+declare
+fun {Reverse S}
+   local I={NewCell S} in
+      local Temp={NewCell nil} in
+         for C in @I do
+            Temp:=C|@Temp
+         end
+         @Temp
+      end
+   end
+end
+
+{Browse {Reverse [1 2 3 4]}}
+{Browse {Reverse nil}}

java_and_dataflow/stack.oz

@@ -0,0 +1,55 @@
+declare
+class Stack
+   attr cell
+
+   meth init
+      cell:=nil
+   end
+
+   meth size($)
+      {Length @cell}
+   end
+
+   meth isEmpty($)
+      @cell==nil
+   end
+
+   meth top($)
+      if @cell==nil then
+         raise topEmptyStack end
+      else @cell.1 end
+   end
+
+   meth push(X)
+      cell:=X|@cell
+   end
+
+   meth pop($)
+      if @cell==nil then
+         raise popEmptyStack end
+      else local H in
+              H = @cell.1
+              cell:=@cell.2
+              H
+           end
+      end
+   end
+end
+
+local S={New Stack init}  in
+   {Browse {S size($)}}
+   {Browse {S isEmpty($)}}
+   %{Browse {S top($)}}
+   {S push(8)}
+   {Browse {S size($)}}
+   {Browse {S isEmpty($)}}
+   {Browse {S top($)}}
+   {Browse {S pop($)}}
+   %{Browse {S pop($)}}
+end
+   
+
+         
+    
+         
+         

java_and_dataflow/stream.oz

@@ -0,0 +1,24 @@
+declare
+proc {Disp S}
+   case S of H|T then {Browse H} {Disp T} end
+end
+
+fun {Prod N}
+   {Delay 1000}
+   N|{Prod N+1}
+end
+
+fun {Trans S}
+   case S of N|T then
+      N*N|{Trans T}
+   end
+end
+
+
+declare S S2
+thread S={Prod 1} end
+thread S2={Trans S} end
+thread {Disp S2} end
+
+%declare S2 in S=a|b|c|S2
+%declare S3 in S2=d|e|f|s3