Delen via

Overzicht: Een Image-Processing-netwerk maken

In dit document ziet u hoe u een netwerk maakt van asynchrone berichtblokken die afbeeldingsverwerking uitvoeren.

Het netwerk bepaalt welke bewerkingen op een afbeelding moeten worden uitgevoerd op basis van de kenmerken ervan. In dit voorbeeld wordt het gegevensstroommodel gebruikt om afbeeldingen via het netwerk te routeren. In het gegevensstroommodel communiceren onafhankelijke onderdelen van een programma met elkaar door berichten te verzenden. Wanneer een onderdeel een bericht ontvangt, kan het een bepaalde actie uitvoeren en vervolgens het resultaat van die actie doorgeven aan een ander onderdeel. Vergelijk dit met het controlestroommodel , waarin een toepassing besturingsstructuren gebruikt, bijvoorbeeld voorwaardelijke instructies, lussen, enzovoort, om de volgorde van bewerkingen in een programma te beheren.

Een netwerk dat is gebaseerd op de gegevensstroom, maakt een pijplijn met taken. Elke fase van de pijplijn voert gelijktijdig een deel van de algehele taak uit. Een analogie hiervan is een assemblagelijn voor de productie van auto's. Als elk voertuig door de montagelijn gaat, stelt één station het frame samen, een andere installeert de motor, enzovoort. Doordat meerdere voertuigen tegelijk kunnen worden gemonteerd, biedt de montagelijn een betere doorvoer dan het één voor één samenstellen van complete voertuigen.

Vereiste voorwaarden

Lees de volgende documenten voordat u aan deze procedure begint:

We raden u ook aan de basisprincipes van GDI+ te begrijpen voordat u aan deze procedure begint.

Afdelingen

Dit stappenplan bevat de volgende onderdelen:

Functionaliteit voor afbeeldingsverwerking definiëren

In deze sectie ziet u de ondersteuningsfuncties die het afbeeldingsverwerkingsnetwerk gebruikt om te werken met afbeeldingen die van schijf worden gelezen.

De volgende functies, GetRGB en MakeColor, extraheren en combineren respectievelijk de componenten van de opgegeven kleur.

// Retrieves the red, green, and blue components from the given
// color value.
void GetRGB(DWORD color, BYTE& r, BYTE& g, BYTE& b)
{
   r = static_cast<BYTE>((color & 0x00ff0000) >> 16);
   g = static_cast<BYTE>((color & 0x0000ff00) >> 8);
   b = static_cast<BYTE>((color & 0x000000ff));
}

// Creates a single color value from the provided red, green, 
// and blue components.
DWORD MakeColor(BYTE r, BYTE g, BYTE b)
{
   return (r<<16) | (g<<8) | (b);
}

Met de volgende functie wordt ProcessImagehet opgegeven std::function-object aangeroepen om de kleurwaarde van elke pixel in een GDI+ Bitmap-object te transformeren. De ProcessImage functie gebruikt het concurrency::parallel_for-algoritme om elke rij van de bitmap parallel te verwerken.

// Calls the provided function for each pixel in a Bitmap object.
void ProcessImage(Bitmap* bmp, const function<void (DWORD&)>& f)
{
   int width = bmp->GetWidth();
   int height = bmp->GetHeight();

   // Lock the bitmap.
   BitmapData bitmapData;
   Rect rect(0, 0, bmp->GetWidth(), bmp->GetHeight());
   bmp->LockBits(&rect, ImageLockModeWrite, PixelFormat32bppRGB, &bitmapData);

   // Get a pointer to the bitmap data.
   DWORD* image_bits = (DWORD*)bitmapData.Scan0;

   // Call the function for each pixel in the image.
   parallel_for (0, height, [&, width](int y)
   {      
      for (int x = 0; x < width; ++x)
      {
         // Get the current pixel value.
         DWORD* curr_pixel = image_bits + (y * width) + x;

         // Call the function.
         f(*curr_pixel);
      }
   });

   // Unlock the bitmap.
   bmp->UnlockBits(&bitmapData);
}

De volgende functies, Grayscale, Sepiatone, ColorMasken Darken, roepen de ProcessImage functie aan om de kleurwaarde van elke pixel in een Bitmap object te transformeren. Elk van deze functies maakt gebruik van een lambda-expressie om de kleurtransformatie van één pixel te definiëren.

// Converts the given image to grayscale.
Bitmap* Grayscale(Bitmap* bmp) 
{
   ProcessImage(bmp, 
      [](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);

         // Set each color component to the average of 
         // the original components.
         BYTE c = (static_cast<WORD>(r) + g + b) / 3;
         color = MakeColor(c, c, c);
      }
   );
   return bmp;
}

// Applies sepia toning to the provided image.
Bitmap* Sepiatone(Bitmap* bmp) 
{
   ProcessImage(bmp, 
      [](DWORD& color) {
         BYTE r0, g0, b0;
         GetRGB(color, r0, g0, b0);

         WORD r1 = static_cast<WORD>((r0 * .393) + (g0 *.769) + (b0 * .189));
         WORD g1 = static_cast<WORD>((r0 * .349) + (g0 *.686) + (b0 * .168));
         WORD b1 = static_cast<WORD>((r0 * .272) + (g0 *.534) + (b0 * .131));

         color = MakeColor(min(0xff, r1), min(0xff, g1), min(0xff, b1));
      }
   );
   return bmp;
}

// Applies the given color mask to each pixel in the provided image.
Bitmap* ColorMask(Bitmap* bmp, DWORD mask)
{
   ProcessImage(bmp, 
      [mask](DWORD& color) {
         color = color & mask;
      }
   );
   return bmp;
}

// Darkens the provided image by the given amount.
Bitmap* Darken(Bitmap* bmp, unsigned int percent)
{
   if (percent > 100)
      throw invalid_argument("Darken: percent must less than 100.");

   double factor = percent / 100.0;

   ProcessImage(bmp, 
      [factor](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);
         r = static_cast<BYTE>(factor*r);
         g = static_cast<BYTE>(factor*g);
         b = static_cast<BYTE>(factor*b);
         color = MakeColor(r, g, b);
      }
   );
   return bmp;
}

Met de volgende functie wordt GetColorDominanceook de ProcessImage functie aangeroepen. In plaats van de waarde van elke kleur te wijzigen, gebruikt deze functie gelijktijdigheid::combineerbare objecten om te berekenen of het rode, groene of blauwe kleuronderdeel de afbeelding overheerst.

// Determines which color component (red, green, or blue) is most dominant
// in the given image and returns a corresponding color mask.
DWORD GetColorDominance(Bitmap* bmp)
{
   // The ProcessImage function processes the image in parallel.
   // The following combinable objects enable the callback function
   // to increment the color counts without using a lock.
   combinable<unsigned int> reds;
   combinable<unsigned int> greens;
   combinable<unsigned int> blues;

   ProcessImage(bmp, 
      [&](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);
         if (r >= g && r >= b)
            reds.local()++;
         else if (g >= r && g >= b)
            greens.local()++;
         else
            blues.local()++;
      }
   );
   
   // Determine which color is dominant and return the corresponding
   // color mask.

   unsigned int r = reds.combine(plus<unsigned int>());
   unsigned int g = greens.combine(plus<unsigned int>());
   unsigned int b = blues.combine(plus<unsigned int>());

   if (r + r >= g + b)
      return 0x00ff0000;
   else if (g + g >= r + b)
      return 0x0000ff00;
   else
      return 0x000000ff;
}

Met de volgende functie wordt GetEncoderClsidde klasse-id opgehaald voor het opgegeven MIME-type van een encoder. De toepassing gebruikt deze functie om de encoder voor een bitmap op te halen.

// Retrieves the class identifier for the given MIME type of an encoder.
int GetEncoderClsid(const WCHAR* format, CLSID* pClsid)
{
   UINT  num = 0;          // number of image encoders
   UINT  size = 0;         // size of the image encoder array in bytes

   ImageCodecInfo* pImageCodecInfo = nullptr;

   GetImageEncodersSize(&num, &size);
   if(size == 0)
      return -1;  // Failure

   pImageCodecInfo = (ImageCodecInfo*)(malloc(size));
   if(pImageCodecInfo == nullptr)
      return -1;  // Failure

   GetImageEncoders(num, size, pImageCodecInfo);

   for(UINT j = 0; j < num; ++j)
   {
      if( wcscmp(pImageCodecInfo[j].MimeType, format) == 0 )
      {
         *pClsid = pImageCodecInfo[j].Clsid;
         free(pImageCodecInfo);
         return j;  // Success
      }    
   }

   free(pImageCodecInfo);
   return -1;  // Failure
}

[Boven]

Het netwerk voor afbeeldingsverwerking maken

In deze sectie wordt beschreven hoe u een netwerk maakt van asynchrone berichtblokken die afbeeldingsverwerking uitvoeren op elke JPEG-afbeelding (.jpg) in een bepaalde map. Het netwerk voert de volgende bewerkingen voor afbeeldingsverwerking uit:

  1. Voor elke afbeelding die is gemaakt door Tom, converteer naar grijswaarden.

  2. Voor elke afbeelding die rood als dominante kleur heeft, verwijdert u de groene en blauwe componenten en maakt u deze donkerder.

  3. Voor een andere afbeelding past u sepia-toning toe.

Het netwerk past alleen de eerste bewerking voor afbeeldingsverwerking toe die overeenkomt met een van deze voorwaarden. Als een afbeelding bijvoorbeeld is gemaakt door Tom en rood heeft als dominante kleur, wordt de afbeelding alleen geconverteerd naar grijswaarden.

Nadat het netwerk elke beeldverwerkingsbewerking heeft uitgevoerd, slaat het de afbeelding op de schijf op als een bitmapbestand (.bmp).

In de volgende stappen ziet u hoe u een functie maakt waarmee dit netwerk voor afbeeldingsverwerking wordt geïmplementeerd en dat netwerk wordt toegepast op elke JPEG-afbeelding in een bepaalde map.

Het netwerk voor afbeeldingsverwerking maken

  1. Maak een functie, ProcessImagesdie de naam van een map op schijf gebruikt.

    void ProcessImages(const wstring& directory)
{
}

  2. Maak in de ProcessImages functie een countdown_event variabele. De countdown_event klasse wordt later in deze gids weergegeven.

    // Holds the number of active image processing operations and 
// signals to the main thread that processing is complete.
countdown_event active(0);

  3. Maak een std::map-object dat een Bitmap object koppelt aan de oorspronkelijke bestandsnaam.

    // Maps Bitmap objects to their original file names.
map<Bitmap*, wstring> bitmap_file_names;

  4. Voeg de volgende code toe om de leden van het netwerk voor afbeeldingsverwerking te definiëren.

     //
 // Create the nodes of the network.
 //

 // Loads Bitmap objects from disk.
 transformer<wstring, Bitmap*> load_bitmap(
    [&](wstring file_name) -> Bitmap* {
       Bitmap* bmp = new Bitmap(file_name.c_str());
       if (bmp != nullptr)
          bitmap_file_names.insert(make_pair(bmp, file_name));
       return bmp;
    }
 );

 // Holds loaded Bitmap objects.
 unbounded_buffer<Bitmap*> loaded_bitmaps;

 // Converts images that are authored by Tom to grayscale.
 transformer<Bitmap*, Bitmap*> grayscale(
    [](Bitmap* bmp) {
       return Grayscale(bmp);
    },
    nullptr,
    [](Bitmap* bmp) -> bool {
       if (bmp == nullptr)
          return false;

       // Retrieve the artist name from metadata.
       UINT size = bmp->GetPropertyItemSize(PropertyTagArtist);
       if (size == 0)
          // Image does not have the Artist property.
          return false;

       PropertyItem* artistProperty = (PropertyItem*) malloc(size);
       bmp->GetPropertyItem(PropertyTagArtist, size, artistProperty);
       string artist(reinterpret_cast<char*>(artistProperty->value));
       free(artistProperty);
       
       return (artist.find("Tom ") == 0);
    }
 );
 
 // Removes the green and blue color components from images that have red as
 // their dominant color.
 transformer<Bitmap*, Bitmap*> colormask(
    [](Bitmap* bmp) {
       return ColorMask(bmp, 0x00ff0000);
    },
    nullptr,
    [](Bitmap* bmp) -> bool { 
       if (bmp == nullptr)
          return false;
       return (GetColorDominance(bmp) == 0x00ff0000);
    }
 );

 // Darkens the color of the provided Bitmap object.
 transformer<Bitmap*, Bitmap*> darken([](Bitmap* bmp) {
    return Darken(bmp, 50);
 });

 // Applies sepia toning to the remaining images.
 transformer<Bitmap*, Bitmap*> sepiatone(
    [](Bitmap* bmp) {
       return Sepiatone(bmp);
    },
    nullptr,
    [](Bitmap* bmp) -> bool { return bmp != nullptr; }
 );

 // Saves Bitmap objects to disk.
 transformer<Bitmap*, Bitmap*> save_bitmap([&](Bitmap* bmp) -> Bitmap* {
    // Replace the file extension with .bmp.
    wstring file_name = bitmap_file_names[bmp];
    file_name.replace(file_name.rfind(L'.') + 1, 3, L"bmp");
    
    // Save the processed image.
    CLSID bmpClsid;
    GetEncoderClsid(L"image/bmp", &bmpClsid);      
    bmp->Save(file_name.c_str(), &bmpClsid);

    return bmp;
 });

 // Deletes Bitmap objects.
 transformer<Bitmap*, Bitmap*> delete_bitmap([](Bitmap* bmp) -> Bitmap* {      
    delete bmp;
    return nullptr;
 });

 // Decrements the event counter.
 call<Bitmap*> decrement([&](Bitmap* _) {      
    active.signal();
 });

  5. Voeg de volgende code toe om verbinding te maken met het netwerk.

    //
// Connect the network.
//   

load_bitmap.link_target(&loaded_bitmaps);

loaded_bitmaps.link_target(&grayscale);
loaded_bitmaps.link_target(&colormask);   
colormask.link_target(&darken);
loaded_bitmaps.link_target(&sepiatone);
loaded_bitmaps.link_target(&decrement);

grayscale.link_target(&save_bitmap);
darken.link_target(&save_bitmap);
sepiatone.link_target(&save_bitmap);

save_bitmap.link_target(&delete_bitmap);
delete_bitmap.link_target(&decrement);

  6. Voeg de volgende code toe om het volledige pad van elk JPEG-bestand in de map naar het hoofd van het netwerk te verzenden.

    // Traverse all files in the directory.
wstring searchPattern = directory;
searchPattern.append(L"\\*");

WIN32_FIND_DATA fileFindData;
HANDLE hFind = FindFirstFile(searchPattern.c_str(), &fileFindData);
if (hFind == INVALID_HANDLE_VALUE) 
   return;
do
{
   if (!(fileFindData.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY))
   {
      wstring file = fileFindData.cFileName;

      // Process only JPEG files.
      if (file.rfind(L".jpg") == file.length() - 4)
      {
         // Form the full path to the file.
         wstring full_path(directory);
         full_path.append(L"\\");
         full_path.append(file);

         // Increment the count of work items.
         active.add_count();

         // Send the path name to the network.
         send(load_bitmap, full_path);
      }
   }
}
while (FindNextFile(hFind, &fileFindData) != 0); 
FindClose(hFind);

  7. Wacht tot de countdown_event variabele nul bereikt.

    // Wait for all operations to finish.
active.wait();

In de volgende tabel worden de leden van het netwerk beschreven.

Lid Beschrijving
load_bitmap Een concurrency::transformer object dat een Bitmap object van schijf laadt en een vermelding toevoegt aan het map object om de afbeelding te koppelen aan de oorspronkelijke bestandsnaam.
loaded_bitmaps Een concurrency::unbounded_buffer-object dat de geladen afbeeldingen naar de filters voor beeldverwerking stuurt.
grayscale Een transformer object dat afbeeldingen omzet die door Tom zijn gemaakt naar grijswaarden. Hierbij worden de metagegevens van de afbeelding gebruikt om de auteur ervan te bepalen.
colormask Een transformer object dat de groene en blauwe kleuronderdelen verwijdert uit afbeeldingen die rood als dominante kleur hebben.
darken Een transformer object dat afbeeldingen donkerder maakt die rood als dominante kleur hebben.
sepiatone Een transformer object dat sepia-toning toepast op afbeeldingen die niet zijn gemaakt door Tom en die niet voornamelijk rood zijn.
save_bitmap Een transformer object dat het verwerkte image object als bitmap opslaat op schijf. save_bitmap haalt de oorspronkelijke bestandsnaam van het map object op en wijzigt de bestandsnaamextensie in .bmp.
delete_bitmap Een transformer object dat het geheugen voor de afbeeldingen vrij maakt.
decrement Een concurrentie::aanroepobject dat fungeert als het eindknooppunt in het netwerk. Het vermindert het object countdown_event om aan te geven aan de hoofdapplicatie dat een afbeelding is verwerkt.

De loaded_bitmaps berichtbuffer is belangrijk omdat deze, als een unbounded_buffer object, Bitmap objecten aan meerdere ontvangers biedt. Wanneer een doelblok een Bitmap object accepteert, biedt het unbounded_buffer object dat Bitmap object niet aan andere doelen. Daarom is de volgorde waarin u objecten koppelt aan een unbounded_buffer object belangrijk. De grayscale, colormasken sepiatone berichtblokken gebruiken elk een filter om alleen bepaalde Bitmap objecten te accepteren. De decrement berichtbuffer is een belangrijk doel van de loaded_bitmaps berichtbuffer omdat deze alle Bitmap objecten accepteert die door de andere berichtbuffers worden geweigerd. Een unbounded_buffer object is vereist om berichten op volgorde door te geven. Daarom blokkeert een unbounded_buffer object totdat een nieuw doelblok eraan is gekoppeld en accepteert het bericht als er geen huidig doelblok dat bericht accepteert.

Als uw toepassing vereist dat meerdere berichtblokken het bericht verwerken, in plaats van alleen het ene berichtblok dat het bericht eerst accepteert, kunt u een ander berichtbloktype gebruiken, zoals overwrite_buffer. De overwrite_buffer klasse bevat één bericht tegelijk, maar het bericht wordt doorgegeven aan elk van de doelen.

In de volgende afbeelding ziet u het netwerk voor afbeeldingsverwerking:

Afbeeldingsverwerkingsnetwerk.

Met het countdown_event object in dit voorbeeld kan het netwerk voor afbeeldingsverwerking de hoofdtoepassing informeren wanneer alle afbeeldingen zijn verwerkt. De countdown_event klasse maakt gebruik van een gelijktijdigheid::gebeurtenisobject om aan te geven wanneer een tellerwaarde nul bereikt. De hoofdtoepassing incrementeert de teller telkens wanneer er een bestandsnaam naar het netwerk wordt verzonden. Het terminale knooppunt van het netwerk vermindert de teller nadat alle afbeeldingen zijn verwerkt. Nadat de hoofdtoepassing de opgegeven map doorkruist, wacht deze totdat het object aangeeft dat de countdown_event teller nul heeft bereikt.

Het volgende voorbeeld toont de countdown_event klasse.

// A synchronization primitive that is signaled when its 
// count reaches zero.
class countdown_event
{
public:
   countdown_event(unsigned int count = 0)
      : _current(static_cast<long>(count)) 
   {
      // Set the event if the initial count is zero.
      if (_current == 0L)
         _event.set();
   }
     
   // Decrements the event counter.
   void signal() {
      if(InterlockedDecrement(&_current) == 0L) {
         _event.set();
      }
   }

   // Increments the event counter.
   void add_count() {
      if(InterlockedIncrement(&_current) == 1L) {
         _event.reset();
      }
   }
   
   // Blocks the current context until the event is set.
   void wait() {
      _event.wait();
   }
 
private:
   // The current count.
   volatile long _current;
   // The event that is set when the counter reaches zero.
   event _event;

   // Disable copy constructor.
   countdown_event(const countdown_event&);
   // Disable assignment.
   countdown_event const & operator=(countdown_event const&);
};

[Boven]

Het volledige voorbeeld

De volgende code toont het volledige voorbeeld. De wmain functie beheert de GDI+-bibliotheek en roept de ProcessImages functie aan om de JPEG-bestanden in de Sample Pictures map te verwerken.

// image-processing-network.cpp
// compile with: /DUNICODE /EHsc image-processing-network.cpp /link gdiplus.lib
#include <windows.h>
#include <gdiplus.h>
#include <iostream>
#include <map>
#include <agents.h>
#include <ppl.h>

using namespace concurrency;
using namespace Gdiplus;
using namespace std;

// Retrieves the red, green, and blue components from the given
// color value.
void GetRGB(DWORD color, BYTE& r, BYTE& g, BYTE& b)
{
   r = static_cast<BYTE>((color & 0x00ff0000) >> 16);
   g = static_cast<BYTE>((color & 0x0000ff00) >> 8);
   b = static_cast<BYTE>((color & 0x000000ff));
}

// Creates a single color value from the provided red, green, 
// and blue components.
DWORD MakeColor(BYTE r, BYTE g, BYTE b)
{
   return (r<<16) | (g<<8) | (b);
}

// Calls the provided function for each pixel in a Bitmap object.
void ProcessImage(Bitmap* bmp, const function<void (DWORD&)>& f)
{
   int width = bmp->GetWidth();
   int height = bmp->GetHeight();

   // Lock the bitmap.
   BitmapData bitmapData;
   Rect rect(0, 0, bmp->GetWidth(), bmp->GetHeight());
   bmp->LockBits(&rect, ImageLockModeWrite, PixelFormat32bppRGB, &bitmapData);

   // Get a pointer to the bitmap data.
   DWORD* image_bits = (DWORD*)bitmapData.Scan0;

   // Call the function for each pixel in the image.
   parallel_for (0, height, [&, width](int y)
   {      
      for (int x = 0; x < width; ++x)
      {
         // Get the current pixel value.
         DWORD* curr_pixel = image_bits + (y * width) + x;

         // Call the function.
         f(*curr_pixel);
      }
   });

   // Unlock the bitmap.
   bmp->UnlockBits(&bitmapData);
}

// Converts the given image to grayscale.
Bitmap* Grayscale(Bitmap* bmp) 
{
   ProcessImage(bmp, 
      [](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);

         // Set each color component to the average of 
         // the original components.
         BYTE c = (static_cast<WORD>(r) + g + b) / 3;
         color = MakeColor(c, c, c);
      }
   );
   return bmp;
}

// Applies sepia toning to the provided image.
Bitmap* Sepiatone(Bitmap* bmp) 
{
   ProcessImage(bmp, 
      [](DWORD& color) {
         BYTE r0, g0, b0;
         GetRGB(color, r0, g0, b0);

         WORD r1 = static_cast<WORD>((r0 * .393) + (g0 *.769) + (b0 * .189));
         WORD g1 = static_cast<WORD>((r0 * .349) + (g0 *.686) + (b0 * .168));
         WORD b1 = static_cast<WORD>((r0 * .272) + (g0 *.534) + (b0 * .131));

         color = MakeColor(min(0xff, r1), min(0xff, g1), min(0xff, b1));
      }
   );
   return bmp;
}

// Applies the given color mask to each pixel in the provided image.
Bitmap* ColorMask(Bitmap* bmp, DWORD mask)
{
   ProcessImage(bmp, 
      [mask](DWORD& color) {
         color = color & mask;
      }
   );
   return bmp;
}

// Darkens the provided image by the given amount.
Bitmap* Darken(Bitmap* bmp, unsigned int percent)
{
   if (percent > 100)
      throw invalid_argument("Darken: percent must less than 100.");

   double factor = percent / 100.0;

   ProcessImage(bmp, 
      [factor](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);
         r = static_cast<BYTE>(factor*r);
         g = static_cast<BYTE>(factor*g);
         b = static_cast<BYTE>(factor*b);
         color = MakeColor(r, g, b);
      }
   );
   return bmp;
}

// Determines which color component (red, green, or blue) is most dominant
// in the given image and returns a corresponding color mask.
DWORD GetColorDominance(Bitmap* bmp)
{
   // The ProcessImage function processes the image in parallel.
   // The following combinable objects enable the callback function
   // to increment the color counts without using a lock.
   combinable<unsigned int> reds;
   combinable<unsigned int> greens;
   combinable<unsigned int> blues;

   ProcessImage(bmp, 
      [&](DWORD& color) {
         BYTE r, g, b;
         GetRGB(color, r, g, b);
         if (r >= g && r >= b)
            reds.local()++;
         else if (g >= r && g >= b)
            greens.local()++;
         else
            blues.local()++;
      }
   );
   
   // Determine which color is dominant and return the corresponding
   // color mask.

   unsigned int r = reds.combine(plus<unsigned int>());
   unsigned int g = greens.combine(plus<unsigned int>());
   unsigned int b = blues.combine(plus<unsigned int>());

   if (r + r >= g + b)
      return 0x00ff0000;
   else if (g + g >= r + b)
      return 0x0000ff00;
   else
      return 0x000000ff;
}

// Retrieves the class identifier for the given MIME type of an encoder.
int GetEncoderClsid(const WCHAR* format, CLSID* pClsid)
{
   UINT  num = 0;          // number of image encoders
   UINT  size = 0;         // size of the image encoder array in bytes

   ImageCodecInfo* pImageCodecInfo = nullptr;

   GetImageEncodersSize(&num, &size);
   if(size == 0)
      return -1;  // Failure

   pImageCodecInfo = (ImageCodecInfo*)(malloc(size));
   if(pImageCodecInfo == nullptr)
      return -1;  // Failure

   GetImageEncoders(num, size, pImageCodecInfo);

   for(UINT j = 0; j < num; ++j)
   {
      if( wcscmp(pImageCodecInfo[j].MimeType, format) == 0 )
      {
         *pClsid = pImageCodecInfo[j].Clsid;
         free(pImageCodecInfo);
         return j;  // Success
      }    
   }

   free(pImageCodecInfo);
   return -1;  // Failure
}

// A synchronization primitive that is signaled when its 
// count reaches zero.
class countdown_event
{
public:
   countdown_event(unsigned int count = 0)
      : _current(static_cast<long>(count)) 
   {
      // Set the event if the initial count is zero.
      if (_current == 0L)
         _event.set();
   }
     
   // Decrements the event counter.
   void signal() {
      if(InterlockedDecrement(&_current) == 0L) {
         _event.set();
      }
   }

   // Increments the event counter.
   void add_count() {
      if(InterlockedIncrement(&_current) == 1L) {
         _event.reset();
      }
   }
   
   // Blocks the current context until the event is set.
   void wait() {
      _event.wait();
   }
 
private:
   // The current count.
   volatile long _current;
   // The event that is set when the counter reaches zero.
   event _event;

   // Disable copy constructor.
   countdown_event(const countdown_event&);
   // Disable assignment.
   countdown_event const & operator=(countdown_event const&);
};

// Demonstrates how to set up a message network that performs a series of 
// image processing operations on each JPEG image in the given directory and
// saves each altered image as a Windows bitmap.
void ProcessImages(const wstring& directory)
{
   // Holds the number of active image processing operations and 
   // signals to the main thread that processing is complete.
   countdown_event active(0);

   // Maps Bitmap objects to their original file names.
   map<Bitmap*, wstring> bitmap_file_names;
      
   //
   // Create the nodes of the network.
   //

   // Loads Bitmap objects from disk.
   transformer<wstring, Bitmap*> load_bitmap(
      [&](wstring file_name) -> Bitmap* {
         Bitmap* bmp = new Bitmap(file_name.c_str());
         if (bmp != nullptr)
            bitmap_file_names.insert(make_pair(bmp, file_name));
         return bmp;
      }
   );

   // Holds loaded Bitmap objects.
   unbounded_buffer<Bitmap*> loaded_bitmaps;
  
   // Converts images that are authored by Tom to grayscale.
   transformer<Bitmap*, Bitmap*> grayscale(
      [](Bitmap* bmp) {
         return Grayscale(bmp);
      },
      nullptr,
      [](Bitmap* bmp) -> bool {
         if (bmp == nullptr)
            return false;

         // Retrieve the artist name from metadata.
         UINT size = bmp->GetPropertyItemSize(PropertyTagArtist);
         if (size == 0)
            // Image does not have the Artist property.
            return false;

         PropertyItem* artistProperty = (PropertyItem*) malloc(size);
         bmp->GetPropertyItem(PropertyTagArtist, size, artistProperty);
         string artist(reinterpret_cast<char*>(artistProperty->value));
         free(artistProperty);
         
         return (artist.find("Tom ") == 0);
      }
   );
   
   // Removes the green and blue color components from images that have red as
   // their dominant color.
   transformer<Bitmap*, Bitmap*> colormask(
      [](Bitmap* bmp) {
         return ColorMask(bmp, 0x00ff0000);
      },
      nullptr,
      [](Bitmap* bmp) -> bool { 
         if (bmp == nullptr)
            return false;
         return (GetColorDominance(bmp) == 0x00ff0000);
      }
   );

   // Darkens the color of the provided Bitmap object.
   transformer<Bitmap*, Bitmap*> darken([](Bitmap* bmp) {
      return Darken(bmp, 50);
   });

   // Applies sepia toning to the remaining images.
   transformer<Bitmap*, Bitmap*> sepiatone(
      [](Bitmap* bmp) {
         return Sepiatone(bmp);
      },
      nullptr,
      [](Bitmap* bmp) -> bool { return bmp != nullptr; }
   );

   // Saves Bitmap objects to disk.
   transformer<Bitmap*, Bitmap*> save_bitmap([&](Bitmap* bmp) -> Bitmap* {
      // Replace the file extension with .bmp.
      wstring file_name = bitmap_file_names[bmp];
      file_name.replace(file_name.rfind(L'.') + 1, 3, L"bmp");
      
      // Save the processed image.
      CLSID bmpClsid;
      GetEncoderClsid(L"image/bmp", &bmpClsid);      
      bmp->Save(file_name.c_str(), &bmpClsid);

      return bmp;
   });

   // Deletes Bitmap objects.
   transformer<Bitmap*, Bitmap*> delete_bitmap([](Bitmap* bmp) -> Bitmap* {      
      delete bmp;
      return nullptr;
   });

   // Decrements the event counter.
   call<Bitmap*> decrement([&](Bitmap* _) {      
      active.signal();
   });

   //
   // Connect the network.
   //   
   
   load_bitmap.link_target(&loaded_bitmaps);
   
   loaded_bitmaps.link_target(&grayscale);
   loaded_bitmaps.link_target(&colormask);   
   colormask.link_target(&darken);
   loaded_bitmaps.link_target(&sepiatone);
   loaded_bitmaps.link_target(&decrement);
   
   grayscale.link_target(&save_bitmap);
   darken.link_target(&save_bitmap);
   sepiatone.link_target(&save_bitmap);
   
   save_bitmap.link_target(&delete_bitmap);
   delete_bitmap.link_target(&decrement);
   
   // Traverse all files in the directory.
   wstring searchPattern = directory;
   searchPattern.append(L"\\*");

   WIN32_FIND_DATA fileFindData;
   HANDLE hFind = FindFirstFile(searchPattern.c_str(), &fileFindData);
   if (hFind == INVALID_HANDLE_VALUE) 
      return;
   do
   {
      if (!(fileFindData.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY))
      {
         wstring file = fileFindData.cFileName;

         // Process only JPEG files.
         if (file.rfind(L".jpg") == file.length() - 4)
         {
            // Form the full path to the file.
            wstring full_path(directory);
            full_path.append(L"\\");
            full_path.append(file);

            // Increment the count of work items.
            active.add_count();

            // Send the path name to the network.
            send(load_bitmap, full_path);
         }
      }
   }
   while (FindNextFile(hFind, &fileFindData) != 0); 
   FindClose(hFind);
      
   // Wait for all operations to finish.
   active.wait();
}

int wmain()
{
   GdiplusStartupInput gdiplusStartupInput;
   ULONG_PTR           gdiplusToken;

   // Initialize GDI+.
   GdiplusStartup(&gdiplusToken, &gdiplusStartupInput, nullptr);

   // Perform image processing.
   // TODO: Change this path if necessary.
   ProcessImages(L"C:\\Users\\Public\\Pictures\\Sample Pictures");

   // Shutdown GDI+.
   GdiplusShutdown(gdiplusToken);
}

In de volgende afbeelding ziet u voorbeelduitvoer. Elke bronafbeelding bevindt zich boven de bijbehorende gewijzigde afbeelding.

Voorbeelduitvoer voor het voorbeeld.

Lighthouse is geschreven door Tom Alphin en wordt daarom omgezet naar grijswaarden. Chrysanthemum, , DesertKoala, en Tulips hebben rood als de dominante kleur en hebben daarom de blauwe en groene kleurcomponenten verwijderd en worden donkerder. Hydrangeas, Jellyfishen Penguins voldoen aan de standaardcriteria en worden daarom sepia-toned.

[Boven]

De code compileren

Kopieer de voorbeeldcode en plak deze in een Visual Studio-project, of plak deze in een bestand met de naam image-processing-network.cpp en voer vervolgens de volgende opdracht uit in een Visual Studio-opdrachtpromptvenster.

cl.exe /DUNICODE /EHsc image-processing-network.cpp /link gdiplus.lib

Zie ook

Gelijktijdigheidsruntime-handleidingen

  • Last updated on