Thorinwasher Comments - Answer Overflow

I think I know what's happening now. I made a disable queue item and an enable queue item. These items sets the value of asyncQueueThreadIsEnabled to true or false. It's a way to avoid dealing with concurrency issues. Now to the actual issue this is how I'm cycling through the queue:

do {
    try {
        Runnable runnable = asyncQueue.take();
        runnable.run();
    } catch (InterruptedException e) {
         Thread.currentThread().interrupt();
    } catch (Exception e) {
         Stargate.log(e);
    }
} while (asyncQueueThreadIsEnabled || !asyncQueue.isEmpty());

do {
    try {
        Runnable runnable = asyncQueue.take();
        runnable.run();
    } catch (InterruptedException e) {
         Thread.currentThread().interrupt();
    } catch (Exception e) {
         Stargate.log(e);
    }
} while (asyncQueueThreadIsEnabled || !asyncQueue.isEmpty());

If per say the last item would be a enable queue item in the queue. Then the boolean switch asyncQueueThreadIsEnabled would be true, therefore blocking the thread in the next BlockingQueue#take() call.

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

Okay. (need to eat some dinner first)

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

(Like my main fallback has just been to let external classes handle this. But in this case, I think I need to get better at concurency)

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

Alright, thanks

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

(Your recomendation here will definitely help, thanks btw)

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

Alright, btw do you have a good source I can read up on concurrency?

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

Let's see, good idea to check that

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

Yeah. Might be a good idea

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

yep

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

It's an task run in another thread, with some wrapper stuff. (mostly because I want to be sure the tasks get executed whenever the srerver shuts down)=

53 replies

JCHJava Community | Help. Code. Learn.

•Created by Thorinwasher on 9/21/2024 in #java-help

Asyncronous task queue

    @Test
    void portalInvalidBlockPlaceTest() {
        Location bottomLeft = new Location(world, 0, 7, 0);
        Location insidePortal = new Location(world, 0, 9, 0);
        Block signBlock = PortalBlockGenerator.generatePortal(bottomLeft);
        Block irisBlock = new Location(world, 1, 9, 0).getBlock();


        ((Directional) signBlock.getBlockData()).setFacing(BlockFace.SOUTH);
        blockEventListener
                .onSignChange(new SignChangeEvent(signBlock, player, new String[]{"test", "", CUSTOM_NETNAME, ""}));

        BlockPlaceEvent event = new BlockPlaceEvent(irisBlock, irisBlock.getState(), irisBlock,
                new ItemStack(Material.ANDESITE), player, false);
        blockEventListener.onBlockPlace(event);
        blockEventListener.onBlockBreak(new BlockBreakEvent(insidePortal.getBlock(), player));
        Assertions.assertTrue(event.isCancelled());
    }

    @Test
    void portalInvalidBlockPlaceTest() {
        Location bottomLeft = new Location(world, 0, 7, 0);
        Location insidePortal = new Location(world, 0, 9, 0);
        Block signBlock = PortalBlockGenerator.generatePortal(bottomLeft);
        Block irisBlock = new Location(world, 1, 9, 0).getBlock();


        ((Directional) signBlock.getBlockData()).setFacing(BlockFace.SOUTH);
        blockEventListener
                .onSignChange(new SignChangeEvent(signBlock, player, new String[]{"test", "", CUSTOM_NETNAME, ""}));

        BlockPlaceEvent event = new BlockPlaceEvent(irisBlock, irisBlock.getState(), irisBlock,
                new ItemStack(Material.ANDESITE), player, false);
        blockEventListener.onBlockPlace(event);
        blockEventListener.onBlockBreak(new BlockBreakEvent(insidePortal.getBlock(), player));
        Assertions.assertTrue(event.isCancelled());
    }