Process1: Initialize a semaphore, and Add to semaphores set (semaphore 0 in example) value 1. And start doing some interprocess work (write to the shared memory for example).
s, err := NewSemaphore(0x12334, 1, 0666, true, IPC_CREAT) if err != nil { panic(err) } err = s.Add(0) if err != nil { panic(err) }After work will be done, just unlock semaphore:
err = s.Done(0) // 0 here is the 1-st semaphore in the set identified by semaphore ID. if err != nil { panic(err) }Process2: Attach to the same semaphore. And Wait until Process1 released semaphore.
s, err := NewSemaphore(0x12334, 1, 0666, false, IPC_CREAT) if err != nil { panic(err) } err = s.Wait() if err != nil { panic(err) }Initialize shared memory segment with a key, required size and flags:
seg1, err := NewSharedMemorySegment(0x1, 1024, S_IRUSR|S_IWUSR|S_IRGRP|S_IWGRP, IPC_CREAT) if err != nil { t.Fatal(err) }Write the specified amount of data and detach from the segment:
// write data to the shared memory // testData is less or equal to 1024 specified in prev declaration seg1.Write([]byte(testData)) err = seg1.Detach() if err != nil { t.Fatal(err) }From the another process, initialize shared memory segment with the same key, size, but with ReadOnly flag:
seg2, err := NewSharedMemorySegment(0x1, 1024, 0, SHM_RDONLY) if err != nil { t.Fatal(err) }Read specified amount of data and detach from the segment:
buf := make([]byte, len(testData), len(testData)) err = seg2.Read(buf) if err != nil { t.Fatal(err) } err = seg2.Detach() if err != nil { t.Fatal(err) }