com.runehive.game.engine.sync.ParallelClientSynchronizer Class Reference

Inheritance diagram for com.runehive.game.engine.sync.ParallelClientSynchronizer:

Collaboration diagram for com.runehive.game.engine.sync.ParallelClientSynchronizer:

Public Member Functions
void	synchronize (MobList< Player > players, MobList< Npc > npcs)

Private Attributes
final Phaser	phaser = new Phaser(1)

Static Private Attributes
static final ExecutorService	executor

Detailed Description

Definition at line 12 of file ParallelClientSynchronizer.java.

Member Function Documentation

synchronize()

void com.runehive.game.engine.sync.ParallelClientSynchronizer.synchronize	(	MobList< Player >	players,
		MobList< Npc >	npcs )

Implements com.runehive.game.engine.sync.ClientSynchronizer.

Definition at line 20 of file ParallelClientSynchronizer.java.

                                                                        {
        // npc movement
/*        phaser.bulkRegister(npcs.size());
        npcs.forEach(npc -> executor.submit(new PhasedUpdateTask(phaser, new NpcPreUpdateTask(npc))));
        phaser.arriveAndAwaitAdvance();*/
 
        // player movement
/*        phaser.bulkRegister(players.size());
        players.forEach(player -> executor.submit(new PhasedUpdateTask(phaser, new PlayerPreUpdateTask(player))));
        phaser.arriveAndAwaitAdvance();*/
 
        // player updating
        phaser.bulkRegister(players.size());
        players.forEach(player -> executor.submit(new PhasedUpdateTask(phaser, new PlayerUpdateTask(player))));
        phaser.arriveAndAwaitAdvance();
 
        // npc updating
        phaser.bulkRegister(players.size());
        players.forEach(player -> executor.submit(new PhasedUpdateTask(phaser, new NpcUpdateTask(player))));
        phaser.arriveAndAwaitAdvance();
 
        // reset npc
        phaser.bulkRegister(npcs.size());
        npcs.forEach(npc -> executor.submit(new PhasedUpdateTask(phaser, new NpcPostUpdateTask(npc))));
        phaser.arriveAndAwaitAdvance();
 
        // reset player
        phaser.bulkRegister(players.size());
        players.forEach(player -> executor.submit(new PhasedUpdateTask(phaser, new PlayerPostUpdateTask(player))));
        phaser.arriveAndAwaitAdvance();
    }

References executor, com.runehive.game.world.entity.MobList< E extends Mob >.forEach(), phaser, and com.runehive.game.world.entity.MobList< E extends Mob >.size.

Here is the call graph for this function:

Member Data Documentation

executor

final ExecutorService com.runehive.game.engine.sync.ParallelClientSynchronizer.executor

staticprivate

Initial value:

= Executors
            .newFixedThreadPool(Runtime.getRuntime().availableProcessors())

Definition at line 14 of file ParallelClientSynchronizer.java.

Referenced by synchronize().

phaser

final Phaser com.runehive.game.engine.sync.ParallelClientSynchronizer.phaser = new Phaser(1)

private

Definition at line 17 of file ParallelClientSynchronizer.java.

Referenced by synchronize().

---

The documentation for this class was generated from the following file:

• java/com/runehive/game/engine/sync/ParallelClientSynchronizer.java