¿Cómo pueden cooperar procesos no relacionados usando un futex?
Digamos que tengo procesos no relacionados, uno es, digamos, un subproceso de apache con mi módulo, otro es, por ejemplo, un script de fondo.
Me gustaría establecer una variable de condición con un mutex entre los dos usando un futex, para beneficiarme de la ruta de código rápida del espacio del usuario.
Me parece que la memoria en la que se almacena mutex podría estar en un archivo mmap 'd, si esa memoria está asignada, por ejemplo, mlock 'd, los dos procesos teóricamente podrían emitir llamadas futex contra la misma dirección.
Alternativamente, quizás se pueda pasar un futex de un proceso a otro usando FUTEX_FD .
Se aceptan envíos de código de bajo, alto nivel y lenguajes dinámicos (C, C++, Python, etc.). La API "robust futex" también debe ser compatible.
Referencias:
mutex se definen para bloquear el acceso a los recursos compartidos. Esto no parece lo que quieres hacer.
si desea que ambos procesos cooperen, puede usar el área mmap compartida o el semáforo
Gracias Phillip y Felix M. por sugerencias.
Código de usuario de Python (el archivo con estructuras de datos ya existe, inicializado con PTHREAD_PROCESS_SHARED )
with open("/tmp/semaphore", "rb+") as f: m = mmap.mmap(f.fileno(), 0) # default: all file, share, read-write data = ffi.cast("unsigned long[3]", id(m))[2] # pointer to mapped area, 64-bit CPython lock = ffi.cast("pthread_mutex_t *", data) cond = ffi.cast("pthread_cond_t *", data + 40) @contextlib.contextmanager def locked(alock): assert not C.pthread_mutex_lock(alock) try: yield finally: assert not C.pthread_mutex_unlock(alock)Espera y despierta:
if "wait" in sys.argv: with locked(lock): assert not C.pthread_cond_wait(cond, lock) elif "signal" in sys.argv: with locked(lock): assert not C.pthread_cond_signal(cond) Conceptos básicos de configuración de PTHREAD_PROCESS_SHARED :
l = ffi.new("pthread_mutexattr_t *") assert not C.pthread_mutexattr_init(l) assert not C.pthread_mutexattr_setpshared(l, 1) # PTHREAD_PROCESS_SHARED assert not C.pthread_mutex_init(lock, l) # same for condition variableCódigo completo para quisquillosos :-) https://github.com/dimaqq/pthread_mutexattr_init/blob/master/xsem.py basado en http://linux.die.net/man/3/pthread_mutexattr_init