Форум администраторов игровых серверов

<?php 

private static class Deallocator

        implements Runnable

    {



        private static Unsafe unsafe = Unsafe.getUnsafe();



        private long address;

        private long size;

        private int capacity;



        private Deallocator(long address, long size, int capacity) {

            assert (address != 0);

            this.address = address;

            this.size = size;

            this.capacity = capacity;

        }



        public void run() {

            if (address == 0) {

                // Paranoia

                return;

            }

            unsafe.freeMemory(address);

            address = 0;

            Bits.unreserveMemory(size, capacity);

        }



    }



    private final Cleaner cleaner;



    public Cleaner cleaner() { return cleaner; }



    // Primary constructor

    //

    DirectByteBuffer(int cap) {                   // package-private



        super(-1, 0, cap, cap);

        boolean pa = VM.isDirectMemoryPageAligned();

        int ps = Bits.pageSize();

        long size = Math.max(1L, (long)cap + (pa ? ps : 0));

        Bits.reserveMemory(size, cap);



        long base = 0;

        try {

            base = unsafe.allocateMemory(size);

        } catch (OutOfMemoryError x) {

            Bits.unreserveMemory(size, cap);

            throw x;

        }

        unsafe.setMemory(base, size, (byte) 0);

        if (pa && (base % ps != 0)) {

            // Round up to page boundary

            address = base + ps - (base & (ps - 1));

        } else {

            address = base;

        }

        cleaner = Cleaner.create(this, new Deallocator(base, size, cap));

        att = null;







    }