まずは、ＭＰＩCH をインストール

http://www.softek.co.jp/SPG/Pgi/TIPS/mpich.html

上記の指示に従って、試してみることにした。
ただし、環境が違うので、環境変数は変更せず、以下のように実行。

# ./configure --with-arch=LINUX -prefix=/usr/local/bin --enable-debug -rsh=ssh
# make
# make install

次に、/etc/profile に root で編集して、/usr/local/bin/bin のパスを通す。

実際に MPICH 付属のサンプルを試してみたら、何とか動いた。


$ mpicc cpi.c
$ mpirun -np 4 a.out
Password:**********
Password:**********
Password:**********
Process 1 on localhost
Process 0 on localhost
Process 2 on localhost
Process 3 on localhost
pi is approximately 3.1416009869231245, Error is 0.0000083333333314
wall clock time = 0.000000

http://www.tohoho-web.com/java/thread.htm

上記ＵＲＬを参考にした。

正解かどうか分からないけど、タネンバウムのモニタを
JAVA で実装したつもり。

synchronized の部分が入るかどうかで、
スレッドの排他を実践できるかどうかが変わる。

ＯＳ本には、コンパイラに依存するとあったので、
そういうものだと飲み込んでみることにした。。。

public class SyncTest {

    static Counter counter = new Counter();

    // Main 
    public static void main(String[] args){
	
	MyThread[] threads = new MyThread[1000];
	for (int i=0; i<1000; i++) {
	    threads[i] = new MyThread();
	    threads[i].start();
	}

        for (int i=0; i<1000; i++) {
            try {
                threads[i].join();
            } catch (InterruptedException e) {
                System.out.println(e);
            }
        }

        System.out.println(SyncTest.counter.count);
    }

}


class MyThread extends Thread {
    public void run(){
	SyncTest.counter.countUp();
    }
}

//synchronized を記述しないと、結果が 995になったりしますが、
//これは、カウンター値を読み出して設定するまでの間に他のスレッドが割り込んでしまい、
//同じ値を読み出して同じ値を設定してしまうために発生します。

class Counter {
    int count;

    void countUp(){

	synchronized (this) {
	    System.out.print("[");
	    int n = count;
	    System.out.print(".");
	    count = n + 1;
	    System.out.print("]");
	}
    }
}


// ちなみに、サンプルではコンストラクタは書かれてなかったが、
// 変数は、０で初期化されてるようですね。
// 危険すぎるかな。。。この書き方は。。。

タネンバウムのセマフォようやく書けました。。。
ふうぅ。。。

=============================

#include <iostream>
#include <sys/shm.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <sys/time.h>

typedef int semaphore;
const int N = 10;
semaphore *mutex;
semaphore *empty;
semaphore *full;

int *store;

void down(std::string s, semaphore &sem)
{
  while (sem <= 0) ;
  sem--;

  std::cout << s << sem << std::endl;
  fflush(stdout);
}

void up  (std::string s, semaphore &sem)
{
  sem++;

  std::cout << s << sem << std::endl;
  fflush(stdout);
}

void producer(void)
{
  while(true){
    std::cout << "--- producer start ---" << std::endl;
    down("p empty ", *empty);
    down("p mutex ", *mutex);
    
    // insert_item
    store[(int)*full] = 1;
    std::cout << "p store: ";
    for (int i=0; i<N; i++) std::cout << store[i] << " ";
    std::cout << std::endl;

    up  ("p mutex ", *mutex);
    up  ("p full  ", *full);
    sleep(1);

    std::cout << "--- producer end ---" << std::endl;
    fflush(stdout);
  }
}

void consumer(void)
{
  while(true){
    std::cout << "--- consumer start ---" << std::endl;
    down("c full  ", *full);
    down("c mutex ", *mutex);

    // remove_item
    store[(int)*full] = 0;
    std::cout << "c store: ";
    for (int i=0; i<N; i++) std::cout << store[i] << " ";
    std::cout << std::endl;

    up  ("c mutex ", *mutex);
    up  ("c empty ", *empty);
    sleep(1);

    std::cout << "--- consumer end ---" << std::endl;
    fflush(stdout);
  }
}

int main (int argc, char* argv[])
{
  const int segment1 = shmget(IPC_PRIVATE, 1, S_IRUSR|S_IWUSR);
  mutex = (semaphore*)shmat(segment1, NULL, 0);
  *mutex = 1;
  
  const int segment2 = shmget(IPC_PRIVATE, 1, S_IRUSR|S_IWUSR);
  empty = (semaphore*)shmat(segment2, NULL, 0);
  *empty = N;

  const int segment3 = shmget(IPC_PRIVATE, 1, S_IRUSR|S_IWUSR);
  full = (semaphore*)shmat(segment3, NULL, 0);
  *full = 0;

  const int segment4 = shmget(IPC_PRIVATE, N, S_IRUSR|S_IWUSR);
  store = (semaphore*)shmat(segment4, NULL, 0);
  for (int i=0; i<N; i++) store[i] = 0;

  const pid_t pid = fork();  

  std::cout << "pid : " << pid << std::endl;
  fflush(stdout);

  if (pid == 0) {
    consumer();
  } else {
    producer();
  }

  shmctl (segment1, IPC_RMID, NULL);
  shmctl (segment2, IPC_RMID, NULL);
  shmctl (segment3, IPC_RMID, NULL);
  shmctl (segment4, IPC_RMID, NULL);

  return 0;
}

 更新。　全然調べてねー

SGML
graphviz

メルセンヌツイスタ
ＤＩコンテナ
ソフトグリッド

多項式時間解法

=======================

【さよならした言葉】

タネンバウム OS

 ということで、残念ながら Haskell 本　買ってしまった。。。（涙）