Estoy trabajando en un algoritmo de emparejamiento de usuarios usando socket.io, y se está ejecutando en Node.js. Quiero asegurarme de que no se repetirán los emparejamientos cuando las personas se conecten.

Los pasos del algoritmo de la siguiente manera:

1. Divida a los jugadores en dos salas, una para minoristas y otra para proveedores.
2. Cuando un jugador ingresa a una de las habitaciones, buscaré la lista de sockets de la otra habitación y emparejaré al jugador con el primer socket.
   • Si el emparejamiento tiene éxito, retire a ambos jugadores de las habitaciones.
   • Si falla (es decir, no hay nadie en la otra habitación), vuelva a intentarlo cada cinco segundos.

No estoy seguro de si habrá algún problema de condición de carrera durante el proceso de obtención de la lista de sockets de la sala. En resumen, ¿es posible que un socket en la lista de sockets se empareje dos veces y ambos emparejamientos tengan éxito?

Aquí está el código:

 const wait = ms => new Promise(resolve => setTimeout(resolve, ms)) io.on('connection', (socket) => { console.log('New websocket connection', socket.id) socket.on('match', async (userId, role, classroomId) => { let roles = { 'retailer': 'supplier', 'supplier': 'retailer' } room = role + classroomId otherroom = roles[role] + classroomId socket.userId = userId socket.join(room) for (let i = 0; i < 60; ++i) { if (socket.rooms.has(room)) { const sockets = await io.in(otherroom).fetchSockets() if (sockets.length > 0 && io.sockets.sockets.get(socket[0].id).rooms.has(otherroom)) { const teammate = io.sockets.sockets.get(sockets[0].id) console.log(teammate.userId) console.log(room, otherroom) socket.leave(room) teammate.leave(room) const pair = await models.Pair.create({ supplierId: role == 'supplier' ? userId : teammate.userId, retailerId: role == 'supplier' ? teammate.userId : userId, currentTime: new Date().toISOString().slice(0, 10) }) io.to(teammate.id).to(socket.id).emit('match-success', pair) console.log((role == 'supplier' ? 's' : 'r'), pair) break } console.log(socket.id, i) // if no match, rematch every 5 seconds. await wait(5000) } else { break } } socket.on('join', (room) => { console.log('join' + room) socket.join(room) }) socket.on('leave', (room, callback) => { socket.leave(room) callback() }) }) })