SkThreadPool< WorkList > Class Template Reference

Inheritance diagram for SkThreadPool< WorkList >:

Public Member Functions
	SkThreadPool (int threads, bool allowBorrowing)
	~SkThreadPool () override
void	add (std::function< void(void)> work) override
void	borrow () override
Public Member Functions inherited from SkExecutor
virtual	~SkExecutor ()

Additional Inherited Members
Static Public Member Functions inherited from SkExecutor
static std::unique_ptr< SkExecutor >	MakeFIFOThreadPool (int threads=0, bool allowBorrowing=true)
static std::unique_ptr< SkExecutor >	MakeLIFOThreadPool (int threads=0, bool allowBorrowing=true)
static SkExecutor &	GetDefault ()
static void	SetDefault (SkExecutor *)
Protected Member Functions inherited from SkExecutor
	SkExecutor ()=default
	SkExecutor (const SkExecutor &)=delete
SkExecutor &	operator= (const SkExecutor &)=delete

Detailed Description

template<typename WorkList>
class SkThreadPool< WorkList >

Definition at line 75 of file SkExecutor.cpp.

Constructor & Destructor Documentation

SkThreadPool()

template<typename WorkList >

SkThreadPool< WorkList >::SkThreadPool ( int  threads, bool  allowBorrowing  )

inlineexplicit

Definition at line 77 of file SkExecutor.cpp.

                                                            : fAllowBorrowing(allowBorrowing) {
        for (int i = 0; i < threads; i++) {
            fThreads.emplace_back(&Loop, this);
        }
    }

~SkThreadPool()

template<typename WorkList >

SkThreadPool< WorkList >::~SkThreadPool ( )

inlineoverride

Definition at line 83 of file SkExecutor.cpp.

                             {
        // Signal each thread that it's time to shut down.
        for (int i = 0; i < fThreads.size(); i++) {
            this->add(nullptr);
        }
        // Wait for each thread to shut down.
        for (int i = 0; i < fThreads.size(); i++) {
            fThreads[i].join();
        }
    }

Member Function Documentation

add()

template<typename WorkList >

void SkThreadPool< WorkList >::add ( std::function< void(void)>  work )

inlineoverridevirtual

Implements SkExecutor.

Definition at line 94 of file SkExecutor.cpp.

                                                    {
        // Add some work to our pile of work to do.
        {
            SkAutoMutexExclusive lock(fWorkLock);
            fWork.emplace_back(std::move(work));
        }
        // Tell the Loop() threads to pick it up.
        fWorkAvailable.signal(1);
    }

borrow()

template<typename WorkList >

void SkThreadPool< WorkList >::borrow ( )

inlineoverridevirtual

Reimplemented from SkExecutor.

Definition at line 104 of file SkExecutor.cpp.

                           {
        // If there is work waiting and we're allowed to borrow work, do it.
        if (fAllowBorrowing && fWorkAvailable.try_wait()) {
            SkAssertResult(this->do_work());
        }
    }

---

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

• third_party/skia/src/core/SkExecutor.cpp